建方式詳解與實(shí)戰(zhàn)對(duì)比)
1. 項(xiàng)目概述為什么線程是Java開發(fā)的必修課在Java開發(fā)的世界里無論你是剛?cè)腴T的新手還是已經(jīng)摸爬滾打多年的老手“多線程”這個(gè)詞都像空氣一樣無處不在卻又常常讓人感到既熟悉又陌生。我見過太多項(xiàng)目初期跑得飛快一旦用戶量上來或者需要處理批量任務(wù)時(shí)程序就變得像老牛拉車一樣慢甚至直接卡死。追根溯源十有八九是線程沒用好。今天我們不談那些高深莫測(cè)的線程池源碼也不扯復(fù)雜的并發(fā)框架就從一個(gè)最基礎(chǔ)、最核心、面試必問的問題入手在Java中如何啟動(dòng)一個(gè)新的線程這個(gè)問題看似簡(jiǎn)單背后卻串聯(lián)起了Java并發(fā)編程的整個(gè)基石。從最原始的Thread類到更優(yōu)雅的Runnable接口再到后來引入的Callable和Future每一種方法都代表了不同時(shí)期的設(shè)計(jì)思想和最佳實(shí)踐。理解它們不僅僅是知道怎么寫代碼更是理解“為什么這么寫”。比如為什么推薦實(shí)現(xiàn)Runnable而不是繼承ThreadCallable比Runnable強(qiáng)在哪里這些選擇直接關(guān)系到你代碼的可維護(hù)性、可擴(kuò)展性甚至是性能。接下來我會(huì)結(jié)合我踩過的坑和實(shí)戰(zhàn)經(jīng)驗(yàn)把這三種方法的來龍去脈、使用場(chǎng)景和隱藏細(xì)節(jié)給你掰開揉碎了講清楚。2. 核心方法一繼承Thread類這是教科書上最常見也是最“原始”的一種方式。它的邏輯非常直白你想創(chuàng)建一個(gè)能獨(dú)立運(yùn)行的線程那就直接創(chuàng)建一個(gè)Thread類的子類。2.1 基礎(chǔ)實(shí)現(xiàn)與原理java.lang.Thread類是Java語言中線程概念的具象化。當(dāng)你繼承它并重寫其run()方法時(shí)你實(shí)際上是在定義這個(gè)線程被啟動(dòng)后要執(zhí)行的具體任務(wù)。public class MyThread extends Thread { Override public void run() { // 這里是新線程要執(zhí)行的代碼 for (int i 0; i 5; i) { System.out.println(Thread.currentThread().getName() 執(zhí)行: i); try { Thread.sleep(500); // 模擬耗時(shí)操作 } catch (InterruptedException e) { e.printStackTrace(); } } } } // 使用方式 public class Main { public static void main(String[] args) { MyThread thread1 new MyThread(); thread1.start(); // 關(guān)鍵調(diào)用start()來啟動(dòng)新線程 // 主線程繼續(xù)執(zhí)行 System.out.println(主線程執(zhí)行完畢。); } }這里有一個(gè)至關(guān)重要的細(xì)節(jié)啟動(dòng)線程必須調(diào)用start()方法而不是直接調(diào)用run()。這是新手最容易栽跟頭的地方。如果你直接調(diào)用thread1.run()那么run()方法里的代碼會(huì)在當(dāng)前通常是main線程中同步執(zhí)行這根本沒有創(chuàng)建任何新線程完全失去了多線程的意義。start()方法是一個(gè)本地方法Native Method它的作用是通知Java虛擬機(jī)JVM去操作系統(tǒng)申請(qǐng)一個(gè)新的系統(tǒng)線程資源然后由這個(gè)新的系統(tǒng)線程去自動(dòng)調(diào)用你重寫的run()方法。這個(gè)過程涉及到用戶態(tài)到內(nèi)核態(tài)的切換是真正的“啟動(dòng)”。2.2 方法優(yōu)劣分析與適用場(chǎng)景優(yōu)點(diǎn)簡(jiǎn)單直觀對(duì)于初學(xué)者來說繼承的思維模式符合直覺易于理解。直接訪問Thread方法在你的自定義線程類內(nèi)部可以直接調(diào)用Thread類的方法如setName(),setPriority()等因?yàn)閠his就是線程對(duì)象本身。缺點(diǎn)與注意事項(xiàng)單繼承限制這是最大的硬傷。Java是單繼承的你的類一旦繼承了Thread就無法再繼承其他任何類。這嚴(yán)重限制了代碼的靈活性。在實(shí)際項(xiàng)目中你的業(yè)務(wù)類很可能需要繼承自某個(gè)框架基類比如HttpServlet這時(shí)再用繼承Thread的方式就行不通了。任務(wù)與線程耦合過緊這種模式下“任務(wù)”即run()方法里的邏輯和“線程執(zhí)行機(jī)制”被捆綁在了一起。從設(shè)計(jì)模式角度看這違反了“單一職責(zé)原則”。線程應(yīng)該是一種執(zhí)行任務(wù)的機(jī)制而任務(wù)本身應(yīng)該是獨(dú)立的。資源共享不便多個(gè)Thread子類的實(shí)例之間如果需要共享數(shù)據(jù)通常需要將數(shù)據(jù)設(shè)置為靜態(tài)static變量或者通過構(gòu)造函數(shù)傳入同一個(gè)對(duì)象引用不如Runnable方式來得自然。適用場(chǎng)景快速原型或演示寫個(gè)小Demo驗(yàn)證想法時(shí)圖個(gè)方便。需要重度定制線程行為當(dāng)你確實(shí)需要重寫Thread類的其他方法雖然這種情況極少時(shí)。明確不需要再繼承其他類的簡(jiǎn)單工具類。實(shí)操心得在我早期的項(xiàng)目中曾因?yàn)閳D省事大量使用繼承Thread的方式。后來當(dāng)業(yè)務(wù)需要引入一個(gè)公共基類時(shí)重構(gòu)代碼成了噩夢(mèng)。我的建議是除非有非常特殊的理由否則在生產(chǎn)代碼中盡量避免這種方式。把它當(dāng)作理解線程概念的起點(diǎn)就好。3. 核心方法二實(shí)現(xiàn)Runnable接口這是目前被廣泛認(rèn)為是最佳實(shí)踐的標(biāo)準(zhǔn)方式。它完美解決了Thread繼承方式的核心痛點(diǎn)。3.1 標(biāo)準(zhǔn)實(shí)現(xiàn)與解耦思想java.lang.Runnable是一個(gè)函數(shù)式接口只有一個(gè)抽象方法run()。它的設(shè)計(jì)精髓在于將“任務(wù)”與“執(zhí)行任務(wù)的線程”進(jìn)行解耦。public class MyRunnable implements Runnable { Override public void run() { // 定義任務(wù)內(nèi)容 for (int i 0; i 5; i) { System.out.println(Thread.currentThread().getName() 執(zhí)行: i); try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } } } } // 使用方式 public class Main { public static void main(String[] args) { // 1. 創(chuàng)建任務(wù)對(duì)象 Runnable task new MyRunnable(); // 2. 創(chuàng)建線程對(duì)象并將任務(wù)傳遞給它 Thread thread1 new Thread(task, “MyThread-1”); // 第二個(gè)參數(shù)可設(shè)置線程名 Thread thread2 new Thread(task); // 也可以不設(shè)置名字 // 3. 啟動(dòng)線程 thread1.start(); thread2.start(); System.out.println(主線程執(zhí)行完畢。); } }這種方式的美妙之處在于MyRunnable類就是一個(gè)純粹的任務(wù)描述類它不關(guān)心自己會(huì)被哪個(gè)線程、以何種方式執(zhí)行。它既可以像上面這樣被多個(gè)Thread包裝執(zhí)行也可以提交給ExecutorService線程池去執(zhí)行復(fù)用性極高。3.2 資源共享的天然優(yōu)勢(shì)實(shí)現(xiàn)Runnable接口的方式為多線程共享資源提供了極其便利的條件。因?yàn)槟憧梢詫⑼粋€(gè)Runnable實(shí)例傳遞給多個(gè)Thread構(gòu)造函數(shù)。public class SharedResourceRunnable implements Runnable { private int ticketCount 10; // 共享資源例如剩余票數(shù) Override public void run() { while (ticketCount 0) { synchronized (this) { // 需要同步控制防止超賣 if (ticketCount 0) { System.out.println(Thread.currentThread().getName() 賣出一張票剩余: (--ticketCount)); } } try { Thread.sleep(100); // 模擬出票時(shí)間 } catch (InterruptedException e) { e.printStackTrace(); } } } } public class Main { public static void main(String[] args) { SharedResourceRunnable task new SharedResourceRunnable(); // 一個(gè)任務(wù)實(shí)例 // 三個(gè)窗口線程同時(shí)賣這10張票 new Thread(task, “窗口1”).start(); new Thread(task, “窗口2”).start(); new Thread(task, “窗口3”).start(); } }在這個(gè)經(jīng)典的“賣票”例子中三個(gè)線程操作的是同一個(gè)task對(duì)象內(nèi)部的ticketCount變量實(shí)現(xiàn)了資源的共享。如果使用繼承Thread的方式你需要費(fèi)勁地將票數(shù)設(shè)為靜態(tài)變量或者通過復(fù)雜的構(gòu)造器傳遞遠(yuǎn)不如這種方式清晰直接。3.3 Lambda表達(dá)式簡(jiǎn)化Java 8從Java 8開始借助Lambda表達(dá)式創(chuàng)建Runnable任務(wù)變得異常簡(jiǎn)潔尤其適合一次性執(zhí)行的簡(jiǎn)單任務(wù)。public class Main { public static void main(String[] args) { // 傳統(tǒng)匿名內(nèi)部類方式 Thread t1 new Thread(new Runnable() { Override public void run() { System.out.println(“匿名內(nèi)部類方式”); } }); // Lambda表達(dá)式方式推薦 Thread t2 new Thread(() - { for (int i 0; i 3; i) { System.out.println(“Lambda線程: ” i); } }); // 甚至更簡(jiǎn)潔單行語句 Thread t3 new Thread(() - System.out.println(“超級(jí)簡(jiǎn)潔的線程任務(wù)”)); t1.start(); t2.start(); t3.start(); } }Lambda表達(dá)式讓線程的創(chuàng)建幾乎沒有任何樣板代碼極大地提升了開發(fā)效率也使得代碼更加聚焦于業(yè)務(wù)邏輯本身。注意事項(xiàng)雖然Lambda很香但也要注意。如果任務(wù)邏輯非常復(fù)雜超過10行或者需要復(fù)用我仍然建議將其抽取成一個(gè)獨(dú)立的、有名字的Runnable實(shí)現(xiàn)類這樣代碼結(jié)構(gòu)更清晰也更利于測(cè)試和維護(hù)。不要為了簡(jiǎn)潔而犧牲可讀性。4. 核心方法三實(shí)現(xiàn)Callable接口與Future前兩種方式Thread.run(),Runnable.run()都有一個(gè)共同的局限它們的run方法返回類型是void。這意味著你無法直接從線程執(zhí)行的任務(wù)中獲取一個(gè)計(jì)算結(jié)果。如果你需要異步計(jì)算一個(gè)值并在主線程中獲取它Callable和Future就是為此而生的黃金搭檔。這是Java 5在java.util.concurrent包中引入的強(qiáng)大工具。4.1 Callable與Runnable的核心區(qū)別CallableV也是一個(gè)函數(shù)式接口它定義了一個(gè)call()方法。與Runnable的run()相比關(guān)鍵區(qū)別有兩點(diǎn)有返回值call()方法返回一個(gè)類型為V的值?？蓲伋鍪軝z異常call()方法聲明了throws Exception允許你將計(jì)算過程中遇到的異常向上拋出而run()方法只能內(nèi)部處理。import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; public class MyCallable implements CallableString { private final String taskName; public MyCallable(String taskName) { this.taskName taskName; } Override public String call() throws Exception { System.out.println(taskName “ 開始執(zhí)行...”); // 模擬一個(gè)耗時(shí)的計(jì)算任務(wù) TimeUnit.SECONDS.sleep(2); int sum 0; for (int i 1; i 100; i) { sum i; } System.out.println(taskName “ 執(zhí)行完畢。”); // 返回計(jì)算結(jié)果 return taskName “ 的計(jì)算結(jié)果是: ” sum; } }4.2 FutureTask連接Callable與Thread的橋梁Thread類的構(gòu)造函數(shù)只能接收Runnable。為了讓Callable能在新線程中運(yùn)行我們需要一個(gè)適配器。FutureTask就是這個(gè)適配器它同時(shí)實(shí)現(xiàn)了Runnable和Future接口。作為Runnable它可以被Thread執(zhí)行。作為Future它提供了方法來檢查計(jì)算是否完成、等待計(jì)算完成并獲取結(jié)果。public class Main { public static void main(String[] args) { // 1. 創(chuàng)建Callable任務(wù) CallableString callableTask new MyCallable(“計(jì)算任務(wù)1”); // 2. 用FutureTask包裝Callable FutureTaskString futureTask new FutureTask(callableTask); // 3. 將FutureTask交給Thread執(zhí)行 Thread thread new Thread(futureTask); thread.start(); // 主線程可以繼續(xù)做其他事情... System.out.println(“主線程在異步任務(wù)執(zhí)行時(shí)可以做別的工作。”); try { // 4. 在需要結(jié)果時(shí)通過FutureTask獲取 // get()方法是阻塞的會(huì)一直等待直到任務(wù)完成并返回結(jié)果 String result futureTask.get(); System.out.println(“獲取到異步結(jié)果: ” result); } catch (InterruptedException e) { // 線程在等待過程中被中斷 e.printStackTrace(); } catch (ExecutionException e) { // Callable任務(wù)執(zhí)行過程中拋出了異常會(huì)被包裝在ExecutionException中 System.out.println(“任務(wù)執(zhí)行出錯(cuò): ” e.getCause()); } } }4.3 Future的核心API與高級(jí)用法Future接口提供了對(duì)異步任務(wù)生命周期的控制get(): 獲取結(jié)果如果任務(wù)還沒完成會(huì)一直阻塞等待。get(long timeout, TimeUnit unit): 帶超時(shí)的獲取。在指定時(shí)間內(nèi)沒得到結(jié)果會(huì)拋出TimeoutException。這是防止線程無限等待、導(dǎo)致程序假死的必備技巧。isDone(): 判斷任務(wù)是否已完成包括正常完成、被取消、發(fā)生異常。cancel(boolean mayInterruptIfRunning): 嘗試取消任務(wù)。如果任務(wù)還沒開始它永遠(yuǎn)不會(huì)運(yùn)行如果任務(wù)正在運(yùn)行mayInterruptIfRunning參數(shù)決定是否向執(zhí)行線程發(fā)送中斷信號(hào)。isCancelled(): 判斷任務(wù)是否在正常完成前被取消。FutureTaskString futureTask new FutureTask(callableTask); new Thread(futureTask).start(); // 主線程先做點(diǎn)別的 TimeUnit.SECONDS.sleep(1); if (!futureTask.isDone()) { System.out.println(“任務(wù)還在進(jìn)行中...”); // 再等最多500毫秒 try { String result futureTask.get(500, TimeUnit.MILLISECONDS); System.out.println(“在超時(shí)前得到結(jié)果: ” result); } catch (TimeoutException e) { System.out.println(“等待超時(shí)決定取消任務(wù)?！?; boolean cancelled futureTask.cancel(true); // true表示嘗試中斷線程 System.out.println(“取消任務(wù)結(jié)果: ” cancelled); } }實(shí)操心得future.get()是一個(gè)阻塞調(diào)用在圖形界面GUI或高并發(fā)服務(wù)的主線程中直接使用它很容易導(dǎo)致界面卡頓或服務(wù)響應(yīng)遲緩。務(wù)必使用帶超時(shí)參數(shù)的get方法或者將get操作也放到一個(gè)后臺(tái)線程中執(zhí)行。更現(xiàn)代的做法是使用CompletableFutureJava 8它提供了非阻塞的回調(diào)機(jī)制但FutureTask是理解這一切的基礎(chǔ)。5. 三種方法的對(duì)比與選型指南了解了三種方法后我們通過一個(gè)表格來直觀對(duì)比幫你做出最佳選擇。特性維度繼承Thread類實(shí)現(xiàn)Runnable接口實(shí)現(xiàn)Callable接口 Future核心區(qū)別線程即任務(wù)任務(wù)與線程分離可返回結(jié)果、可拋異常的任務(wù)返回值無 (void run())無 (void run())有 (V call())異常處理只能在run()內(nèi)try-catch只能在run()內(nèi)try-catch可拋出Exception由調(diào)用方處理繼承限制受Java單繼承限制不靈活無限制可實(shí)現(xiàn)多個(gè)接口靈活性高無限制靈活性高資源共享較麻煩需static或傳參非常方便共享同一實(shí)例方便共享同一Callable或FutureTask代碼復(fù)雜度低但耦合高低推薦中需處理Future線程池兼容可直接提交但設(shè)計(jì)不佳天然適合提交給線程池天然適合提交給線程池適用場(chǎng)景簡(jiǎn)單Demo、特定定制絕大多數(shù)業(yè)務(wù)場(chǎng)景、異步任務(wù)需要獲取結(jié)果的異步計(jì)算、并行計(jì)算選型決策流你的任務(wù)需要返回一個(gè)結(jié)果嗎是- 毫不猶豫選擇CallableFuture。否- 進(jìn)入下一步。你的任務(wù)類還需要繼承其他類嗎是- 選擇Runnable。否- 進(jìn)入下一步。你只是寫一個(gè)臨時(shí)測(cè)試或者有特殊線程行為要重寫是- 可以考慮Thread但請(qǐng)清楚其局限性。否-默認(rèn)且推薦選擇Runnable。簡(jiǎn)單來說Runnable是通用解Callable是需返回值時(shí)的特化解而繼承Thread在大多數(shù)生產(chǎn)代碼中應(yīng)被視為遺留方式或特殊用途。6. 從手動(dòng)創(chuàng)建線程到線程池的最佳實(shí)踐演進(jìn)雖然學(xué)會(huì)了三種啟動(dòng)線程的方法但在真實(shí)的、嚴(yán)肅的生產(chǎn)環(huán)境中直接new Thread()并start()被視為一種反模式。原因如下資源消耗大創(chuàng)建和銷毀一個(gè)操作系統(tǒng)線程的成本非常高。頻繁創(chuàng)建會(huì)消耗大量系統(tǒng)資源。管理困難無法有效控制系統(tǒng)中并發(fā)線程的數(shù)量太多線程會(huì)導(dǎo)致過度切換性能下降太少則無法充分利用CPU。功能缺失缺乏統(tǒng)一的管理如定時(shí)執(zhí)行、定期執(zhí)行、線程中斷策略等。線程池ExecutorService是解決這些問題的標(biāo)準(zhǔn)答案。它預(yù)先創(chuàng)建好一批線程工作線程形成一個(gè)“池子”。當(dāng)有任務(wù)Runnable或Callable提交時(shí)池子分配一個(gè)空閑線程來執(zhí)行。任務(wù)執(zhí)行完畢后線程不銷毀而是回到池中等待下一個(gè)任務(wù)。這實(shí)現(xiàn)了線程的復(fù)用極大地降低了開銷。import java.util.concurrent.*; public class ThreadPoolDemo { public static void main(String[] args) throws ExecutionException, InterruptedException { // 1. 創(chuàng)建線程池 (核心線程數(shù)2最大線程數(shù)5空閑存活時(shí)間1秒任務(wù)隊(duì)列容量10) ExecutorService executor new ThreadPoolExecutor( 2, 5, 1L, TimeUnit.SECONDS, new ArrayBlockingQueue(10), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy() // 拒絕策略直接拋出異常 ); // 2. 提交Runnable任務(wù)無返回值 executor.execute(() - System.out.println(“執(zhí)行Runnable任務(wù): ” Thread.currentThread().getName())); // 3. 提交Callable任務(wù)有返回值 FutureString future executor.submit(() - { TimeUnit.SECONDS.sleep(1); return “Callable任務(wù)結(jié)果”; }); // 4. 獲取結(jié)果 System.out.println(“Future result: ” future.get()); // 5. 優(yōu)雅關(guān)閉線程池重要 executor.shutdown(); // 停止接收新任務(wù)等待已提交任務(wù)完成 // executor.shutdownNow(); // 嘗試立即停止所有正在執(zhí)行的任務(wù) boolean isTerminated executor.awaitTermination(5, TimeUnit.SECONDS); // 等待關(guān)閉 if (!isTerminated) { System.out.println(“仍有任務(wù)未完成強(qiáng)制關(guān)閉...”); } } }線程池配置的核心參數(shù)關(guān)系對(duì)應(yīng)網(wǎng)絡(luò)熱詞中的疑問corePoolSize核心線程數(shù)池中常駐的線程數(shù)量即使空閑也不會(huì)被回收除非設(shè)置了allowCoreThreadTimeOut。maximumPoolSize最大線程數(shù)池中允許的最大線程數(shù)。workQueue任務(wù)隊(duì)列用于存放等待執(zhí)行的任務(wù)的阻塞隊(duì)列。queueCapacity隊(duì)列大小與并發(fā)量的關(guān)系當(dāng)任務(wù)提交時(shí)如果運(yùn)行線程數(shù) corePoolSize則創(chuàng)建新線程執(zhí)行。如果運(yùn)行線程數(shù) corePoolSize則將任務(wù)放入隊(duì)列。如果隊(duì)列已滿且運(yùn)行線程數(shù) maximumPoolSize則創(chuàng)建新線程執(zhí)行。如果隊(duì)列已滿且運(yùn)行線程數(shù) maximumPoolSize則觸發(fā)拒絕策略。系統(tǒng)最大并發(fā)量估算這取決于你的系統(tǒng)資源CPU核心數(shù)、內(nèi)存、I/O和任務(wù)類型CPU密集型、I/O密集型。一個(gè)粗略的起點(diǎn)是對(duì)于CPU密集型任務(wù)線程數(shù)可設(shè)為CPU核數(shù) 1對(duì)于I/O密集型任務(wù)可設(shè)為CPU核數(shù) * (1 平均等待時(shí)間/平均計(jì)算時(shí)間)。隊(duì)列容量需要根據(jù)任務(wù)的平均處理速度和突發(fā)流量來設(shè)定起到“削峰填谷”的作用防止瞬間流量擊垮系統(tǒng)。避坑指南絕對(duì)不要使用Executors的快捷工廠方法如newFixedThreadPool,newCachedThreadPool而不了解其內(nèi)部隊(duì)列newFixedThreadPool使用無界隊(duì)列LinkedBlockingQueue任務(wù)過多會(huì)導(dǎo)致內(nèi)存耗盡newCachedThreadPool最大線程數(shù)是Integer.MAX_VALUE可能創(chuàng)建海量線程拖垮系統(tǒng)。生產(chǎn)環(huán)境務(wù)必使用ThreadPoolExecutor構(gòu)造函數(shù)根據(jù)實(shí)際情況明確指定所有參數(shù)。7. 常見問題與實(shí)戰(zhàn)排查技巧即使理解了原理在實(shí)際編碼和運(yùn)行時(shí)多線程程序依然像一座布滿暗礁的海洋。下面是我總結(jié)的一些最常見的問題和排查思路。7.1 線程安全與數(shù)據(jù)競(jìng)爭(zhēng)這是多線程編程的萬惡之源。當(dāng)多個(gè)線程未經(jīng)同步控制訪問和修改同一共享數(shù)據(jù)時(shí)就會(huì)發(fā)生數(shù)據(jù)競(jìng)爭(zhēng)導(dǎo)致結(jié)果不可預(yù)測(cè)。問題現(xiàn)象程序多次運(yùn)行結(jié)果不一致計(jì)數(shù)器的值最終小于預(yù)期如前面賣票例子可能賣出超過10張票。解決方案synchronized關(guān)鍵字最基礎(chǔ)的互斥鎖。可以修飾方法或代碼塊。// 同步代碼塊 synchronized(lockObject) { // 訪問共享資源的代碼 } // 同步實(shí)例方法鎖是當(dāng)前實(shí)例this public synchronized void increment() { ... } // 同步靜態(tài)方法鎖是當(dāng)前類的Class對(duì)象 public static synchronized void staticIncrement() { ... }java.util.concurrent.locks.Lock接口更靈活、功能更強(qiáng)的鎖如ReentrantLock。支持嘗試非阻塞獲取鎖、可中斷、公平鎖等特性。private final Lock lock new ReentrantLock(); public void safeMethod() { lock.lock(); // 獲取鎖 try { // 訪問共享資源 } finally { lock.unlock(); // 務(wù)必在finally中釋放鎖 } }使用線程安全的數(shù)據(jù)結(jié)構(gòu)ConcurrentHashMap,CopyOnWriteArrayList,AtomicInteger等。它們?cè)趦?nèi)部實(shí)現(xiàn)了高效的線程安全機(jī)制多數(shù)情況下應(yīng)優(yōu)先考慮使用它們而非自己加鎖。7.2 死鎖Deadlock兩個(gè)或更多線程互相等待對(duì)方持有的鎖導(dǎo)致所有線程都無法繼續(xù)執(zhí)行。問題現(xiàn)象程序“卡住”了日志停止輸出CPU占用率可能很低但程序無響應(yīng)。產(chǎn)生條件四個(gè)必要條件缺一不可互斥條件請(qǐng)求與保持條件不剝奪條件循環(huán)等待條件排查與解決使用JDK工具運(yùn)行程序后用jstack -l pid命令或JVisualVM等圖形工具查看線程轉(zhuǎn)儲(chǔ)Thread Dump。在輸出中搜索“deadlock”關(guān)鍵詞JDK通常會(huì)幫你分析并指出死鎖的線程和鎖信息。避免策略固定鎖的獲取順序所有線程都按相同的全局順序例如按對(duì)象的哈希值排序申請(qǐng)鎖。使用帶超時(shí)的鎖如Lock.tryLock(long time, TimeUnit unit)獲取不到鎖一段時(shí)間后放棄并釋放自己已持有的鎖。降低鎖的粒度盡量只鎖住必要的共享數(shù)據(jù)而不是大段代碼或整個(gè)對(duì)象。7.3 線程間協(xié)作wait(), notify(), notifyAll()當(dāng)線程需要等待某個(gè)條件滿足時(shí)如生產(chǎn)者-消費(fèi)者模型需要使用Object類的這組方法。它們必須在synchronized同步塊內(nèi)調(diào)用。public class ProducerConsumer { private final QueueString queue new LinkedList(); private final int MAX_SIZE 5; private final Object lock new Object(); public void produce(String item) throws InterruptedException { synchronized (lock) { while (queue.size() MAX_SIZE) { // 必須用while不能用if防止虛假喚醒 lock.wait(); // 釋放lock鎖并等待 } queue.offer(item); System.out.println(“生產(chǎn): ” item); lock.notifyAll(); // 通知所有等待的消費(fèi)者線程 } } public String consume() throws InterruptedException { synchronized (lock) { while (queue.isEmpty()) { lock.wait(); } String item queue.poll(); System.out.println(“消費(fèi): ” item); lock.notifyAll(); // 通知生產(chǎn)者線程 return item; } } }關(guān)鍵細(xì)節(jié)判斷條件時(shí)必須使用while循環(huán)而不是if語句。這是因?yàn)榇嬖凇疤摷賳拘选眘purious wakeup——線程可能在沒有被notify的情況下從wait()中返回。用while可以確保被喚醒后再次檢查條件是否真正滿足。7.4 內(nèi)存可見性與volatile關(guān)鍵字由于Java內(nèi)存模型JMM和CPU緩存的存在一個(gè)線程對(duì)共享變量的修改可能不會(huì)立即被其他線程看到。問題現(xiàn)象一個(gè)線程修改了boolean flag false為true但另一個(gè)線程卻一直讀不到變化導(dǎo)致循環(huán)無法退出。解決方案使用volatile關(guān)鍵字修飾變量volatile保證了變量的可見性一個(gè)線程的修改能立刻被其他線程看到和有序性防止指令重排序但不保證原子性復(fù)合操作仍需同步。private volatile boolean running true; public void stop() { running false; // 寫操作對(duì)其他線程立即可見 } public void run() { while (running) { // 讀操作總能讀到最新值 // do work } }使用synchronized或Lock鎖的釋放和獲取會(huì)隱式地觸發(fā)內(nèi)存屏障保證可見性。使用Atomic類如AtomicBoolean它內(nèi)部使用了volatile和CAS操作既保證了可見性又保證了簡(jiǎn)單操作的原子性。7.5 資源管理與線程中斷線程可能因?yàn)镮/O阻塞、鎖等待、sleep()等原因而處于非運(yùn)行狀態(tài)。正確的中斷和關(guān)閉線程是良好編程習(xí)慣的一部分。正確的中斷響應(yīng)Thread.interrupt()方法只是給線程設(shè)置一個(gè)中斷標(biāo)志位。線程需要自己檢查這個(gè)標(biāo)志并做出響應(yīng)。public class InterruptibleTask implements Runnable { Override public void run() { // 正確做法定期檢查中斷狀態(tài) while (!Thread.currentThread().isInterrupted()) { try { // 如果任務(wù)中有可中斷的阻塞調(diào)用如Thread.sleep, Object.wait, BlockingQueue.take // 這些方法在收到中斷信號(hào)時(shí)會(huì)拋出InterruptedException TimeUnit.SECONDS.sleep(1); // ... 執(zhí)行工作 } catch (InterruptedException e) { // 捕獲到InterruptedException后中斷狀態(tài)會(huì)被清除 System.out.println(“任務(wù)被中斷準(zhǔn)備退出。”); // 恢復(fù)中斷狀態(tài)這是一個(gè)重要技巧讓調(diào)用者知道發(fā)生了中斷 Thread.currentThread().interrupt(); break; // 退出循環(huán) } } System.out.println(“線程安全結(jié)束?！?; } }關(guān)閉線程池如前所述務(wù)必調(diào)用shutdown()或shutdownNow()來優(yōu)雅關(guān)閉線程池否則JVM可能無法正常退出。多線程編程的復(fù)雜性要求我們不僅要知道如何啟動(dòng)線程更要深刻理解其背后的并發(fā)原理、潛在陷阱和最佳實(shí)踐。從最基本的三種啟動(dòng)方式入手逐步深入到線程池、鎖、原子變量等并發(fā)工具最終構(gòu)建出健壯、高效的多線程應(yīng)用這是一個(gè)Java開發(fā)者成長的必經(jīng)之路。每一次踩坑和解決問題的經(jīng)歷都會(huì)讓你對(duì)“并發(fā)”二字的理解更加深刻。 Java多線程入門：Thread、Runnable、Callable三種創(chuàng)建方式詳解與實(shí)戰(zhàn)對(duì)比
1. 項(xiàng)目概述為什么線程是Java開發(fā)的必修課在Java開發(fā)的世界里無論你是剛?cè)腴T的新手還是已經(jīng)摸爬滾打多年的老手“多線程”這個(gè)詞都像空氣一樣無處不在卻又常常讓人感到既熟悉又陌生。我見過太多項(xiàng)目初期跑得飛快一旦用戶量上來或者需要處理批量任務(wù)時(shí)程序就變得像老牛拉車一樣慢甚至直接卡死。追根溯源十有八九是線程沒用好。今天我們不談那些高深莫測(cè)的線程池源碼也不扯復(fù)雜的并發(fā)框架就從一個(gè)最基礎(chǔ)、最核心、面試必問的問題入手在Java中如何啟動(dòng)一個(gè)新的線程這個(gè)問題看似簡(jiǎn)單背后卻串聯(lián)起了Java并發(fā)編程的整個(gè)基石。從最原始的Thread類到更優(yōu)雅的Runnable接口再到后來引入的Callable和Future每一種方法都代表了不同時(shí)期的設(shè)計(jì)思想和最佳實(shí)踐。理解它們不僅僅是知道怎么寫代碼更是理解“為什么這么寫”。比如為什么推薦實(shí)現(xiàn)Runnable而不是繼承ThreadCallable比Runnable強(qiáng)在哪里這些選擇直接關(guān)系到你代碼的可維護(hù)性、可擴(kuò)展性甚至是性能。接下來我會(huì)結(jié)合我踩過的坑和實(shí)戰(zhàn)經(jīng)驗(yàn)把這三種方法的來龍去脈、使用場(chǎng)景和隱藏細(xì)節(jié)給你掰開揉碎了講清楚。2. 核心方法一繼承Thread類這是教科書上最常見也是最“原始”的一種方式。它的邏輯非常直白你想創(chuàng)建一個(gè)能獨(dú)立運(yùn)行的線程那就直接創(chuàng)建一個(gè)Thread類的子類。2.1 基礎(chǔ)實(shí)現(xiàn)與原理java.lang.Thread類是Java語言中線程概念的具象化。當(dāng)你繼承它并重寫其run()方法時(shí)你實(shí)際上是在定義這個(gè)線程被啟動(dòng)后要執(zhí)行的具體任務(wù)。public class MyThread extends Thread { Override public void run() { // 這里是新線程要執(zhí)行的代碼 for (int i 0; i 5; i) { System.out.println(Thread.currentThread().getName() 執(zhí)行: i); try { Thread.sleep(500); // 模擬耗時(shí)操作 } catch (InterruptedException e) { e.printStackTrace(); } } } } // 使用方式 public class Main { public static void main(String[] args) { MyThread thread1 new MyThread(); thread1.start(); // 關(guān)鍵調(diào)用start()來啟動(dòng)新線程 // 主線程繼續(xù)執(zhí)行 System.out.println(主線程執(zhí)行完畢。); } }這里有一個(gè)至關(guān)重要的細(xì)節(jié)啟動(dòng)線程必須調(diào)用start()方法而不是直接調(diào)用run()。這是新手最容易栽跟頭的地方。如果你直接調(diào)用thread1.run()那么run()方法里的代碼會(huì)在當(dāng)前通常是main線程中同步執(zhí)行這根本沒有創(chuàng)建任何新線程完全失去了多線程的意義。start()方法是一個(gè)本地方法Native Method它的作用是通知Java虛擬機(jī)JVM去操作系統(tǒng)申請(qǐng)一個(gè)新的系統(tǒng)線程資源然后由這個(gè)新的系統(tǒng)線程去自動(dòng)調(diào)用你重寫的run()方法。這個(gè)過程涉及到用戶態(tài)到內(nèi)核態(tài)的切換是真正的“啟動(dòng)”。2.2 方法優(yōu)劣分析與適用場(chǎng)景優(yōu)點(diǎn)簡(jiǎn)單直觀對(duì)于初學(xué)者來說繼承的思維模式符合直覺易于理解。直接訪問Thread方法在你的自定義線程類內(nèi)部可以直接調(diào)用Thread類的方法如setName(),setPriority()等因?yàn)閠his就是線程對(duì)象本身。缺點(diǎn)與注意事項(xiàng)單繼承限制這是最大的硬傷。Java是單繼承的你的類一旦繼承了Thread就無法再繼承其他任何類。這嚴(yán)重限制了代碼的靈活性。在實(shí)際項(xiàng)目中你的業(yè)務(wù)類很可能需要繼承自某個(gè)框架基類比如HttpServlet這時(shí)再用繼承Thread的方式就行不通了。任務(wù)與線程耦合過緊這種模式下“任務(wù)”即run()方法里的邏輯和“線程執(zhí)行機(jī)制”被捆綁在了一起。從設(shè)計(jì)模式角度看這違反了“單一職責(zé)原則”。線程應(yīng)該是一種執(zhí)行任務(wù)的機(jī)制而任務(wù)本身應(yīng)該是獨(dú)立的。資源共享不便多個(gè)Thread子類的實(shí)例之間如果需要共享數(shù)據(jù)通常需要將數(shù)據(jù)設(shè)置為靜態(tài)static變量或者通過構(gòu)造函數(shù)傳入同一個(gè)對(duì)象引用不如Runnable方式來得自然。適用場(chǎng)景快速原型或演示寫個(gè)小Demo驗(yàn)證想法時(shí)圖個(gè)方便。需要重度定制線程行為當(dāng)你確實(shí)需要重寫Thread類的其他方法雖然這種情況極少時(shí)。明確不需要再繼承其他類的簡(jiǎn)單工具類。實(shí)操心得在我早期的項(xiàng)目中曾因?yàn)閳D省事大量使用繼承Thread的方式。后來當(dāng)業(yè)務(wù)需要引入一個(gè)公共基類時(shí)重構(gòu)代碼成了噩夢(mèng)。我的建議是除非有非常特殊的理由否則在生產(chǎn)代碼中盡量避免這種方式。把它當(dāng)作理解線程概念的起點(diǎn)就好。3. 核心方法二實(shí)現(xiàn)Runnable接口這是目前被廣泛認(rèn)為是最佳實(shí)踐的標(biāo)準(zhǔn)方式。它完美解決了Thread繼承方式的核心痛點(diǎn)。3.1 標(biāo)準(zhǔn)實(shí)現(xiàn)與解耦思想java.lang.Runnable是一個(gè)函數(shù)式接口只有一個(gè)抽象方法run()。它的設(shè)計(jì)精髓在于將“任務(wù)”與“執(zhí)行任務(wù)的線程”進(jìn)行解耦。public class MyRunnable implements Runnable { Override public void run() { // 定義任務(wù)內(nèi)容 for (int i 0; i 5; i) { System.out.println(Thread.currentThread().getName() 執(zhí)行: i); try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } } } } // 使用方式 public class Main { public static void main(String[] args) { // 1. 創(chuàng)建任務(wù)對(duì)象 Runnable task new MyRunnable(); // 2. 創(chuàng)建線程對(duì)象并將任務(wù)傳遞給它 Thread thread1 new Thread(task, “MyThread-1”); // 第二個(gè)參數(shù)可設(shè)置線程名 Thread thread2 new Thread(task); // 也可以不設(shè)置名字 // 3. 啟動(dòng)線程 thread1.start(); thread2.start(); System.out.println(主線程執(zhí)行完畢。); } }這種方式的美妙之處在于MyRunnable類就是一個(gè)純粹的任務(wù)描述類它不關(guān)心自己會(huì)被哪個(gè)線程、以何種方式執(zhí)行。它既可以像上面這樣被多個(gè)Thread包裝執(zhí)行也可以提交給ExecutorService線程池去執(zhí)行復(fù)用性極高。3.2 資源共享的天然優(yōu)勢(shì)實(shí)現(xiàn)Runnable接口的方式為多線程共享資源提供了極其便利的條件。因?yàn)槟憧梢詫⑼粋€(gè)Runnable實(shí)例傳遞給多個(gè)Thread構(gòu)造函數(shù)。public class SharedResourceRunnable implements Runnable { private int ticketCount 10; // 共享資源例如剩余票數(shù) Override public void run() { while (ticketCount 0) { synchronized (this) { // 需要同步控制防止超賣 if (ticketCount 0) { System.out.println(Thread.currentThread().getName() 賣出一張票剩余: (--ticketCount)); } } try { Thread.sleep(100); // 模擬出票時(shí)間 } catch (InterruptedException e) { e.printStackTrace(); } } } } public class Main { public static void main(String[] args) { SharedResourceRunnable task new SharedResourceRunnable(); // 一個(gè)任務(wù)實(shí)例 // 三個(gè)窗口線程同時(shí)賣這10張票 new Thread(task, “窗口1”).start(); new Thread(task, “窗口2”).start(); new Thread(task, “窗口3”).start(); } }在這個(gè)經(jīng)典的“賣票”例子中三個(gè)線程操作的是同一個(gè)task對(duì)象內(nèi)部的ticketCount變量實(shí)現(xiàn)了資源的共享。如果使用繼承Thread的方式你需要費(fèi)勁地將票數(shù)設(shè)為靜態(tài)變量或者通過復(fù)雜的構(gòu)造器傳遞遠(yuǎn)不如這種方式清晰直接。3.3 Lambda表達(dá)式簡(jiǎn)化Java 8從Java 8開始借助Lambda表達(dá)式創(chuàng)建Runnable任務(wù)變得異常簡(jiǎn)潔尤其適合一次性執(zhí)行的簡(jiǎn)單任務(wù)。public class Main { public static void main(String[] args) { // 傳統(tǒng)匿名內(nèi)部類方式 Thread t1 new Thread(new Runnable() { Override public void run() { System.out.println(“匿名內(nèi)部類方式”); } }); // Lambda表達(dá)式方式推薦 Thread t2 new Thread(() - { for (int i 0; i 3; i) { System.out.println(“Lambda線程: ” i); } }); // 甚至更簡(jiǎn)潔單行語句 Thread t3 new Thread(() - System.out.println(“超級(jí)簡(jiǎn)潔的線程任務(wù)”)); t1.start(); t2.start(); t3.start(); } }Lambda表達(dá)式讓線程的創(chuàng)建幾乎沒有任何樣板代碼極大地提升了開發(fā)效率也使得代碼更加聚焦于業(yè)務(wù)邏輯本身。注意事項(xiàng)雖然Lambda很香但也要注意。如果任務(wù)邏輯非常復(fù)雜超過10行或者需要復(fù)用我仍然建議將其抽取成一個(gè)獨(dú)立的、有名字的Runnable實(shí)現(xiàn)類這樣代碼結(jié)構(gòu)更清晰也更利于測(cè)試和維護(hù)。不要為了簡(jiǎn)潔而犧牲可讀性。4. 核心方法三實(shí)現(xiàn)Callable接口與Future前兩種方式Thread.run(),Runnable.run()都有一個(gè)共同的局限它們的run方法返回類型是void。這意味著你無法直接從線程執(zhí)行的任務(wù)中獲取一個(gè)計(jì)算結(jié)果。如果你需要異步計(jì)算一個(gè)值并在主線程中獲取它Callable和Future就是為此而生的黃金搭檔。這是Java 5在java.util.concurrent包中引入的強(qiáng)大工具。4.1 Callable與Runnable的核心區(qū)別CallableV也是一個(gè)函數(shù)式接口它定義了一個(gè)call()方法。與Runnable的run()相比關(guān)鍵區(qū)別有兩點(diǎn)有返回值call()方法返回一個(gè)類型為V的值?？蓲伋鍪軝z異常call()方法聲明了throws Exception允許你將計(jì)算過程中遇到的異常向上拋出而run()方法只能內(nèi)部處理。import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; public class MyCallable implements CallableString { private final String taskName; public MyCallable(String taskName) { this.taskName taskName; } Override public String call() throws Exception { System.out.println(taskName “ 開始執(zhí)行...”); // 模擬一個(gè)耗時(shí)的計(jì)算任務(wù) TimeUnit.SECONDS.sleep(2); int sum 0; for (int i 1; i 100; i) { sum i; } System.out.println(taskName “ 執(zhí)行完畢。”); // 返回計(jì)算結(jié)果 return taskName “ 的計(jì)算結(jié)果是: ” sum; } }4.2 FutureTask連接Callable與Thread的橋梁Thread類的構(gòu)造函數(shù)只能接收Runnable。為了讓Callable能在新線程中運(yùn)行我們需要一個(gè)適配器。FutureTask就是這個(gè)適配器它同時(shí)實(shí)現(xiàn)了Runnable和Future接口。作為Runnable它可以被Thread執(zhí)行。作為Future它提供了方法來檢查計(jì)算是否完成、等待計(jì)算完成并獲取結(jié)果。public class Main { public static void main(String[] args) { // 1. 創(chuàng)建Callable任務(wù) CallableString callableTask new MyCallable(“計(jì)算任務(wù)1”); // 2. 用FutureTask包裝Callable FutureTaskString futureTask new FutureTask(callableTask); // 3. 將FutureTask交給Thread執(zhí)行 Thread thread new Thread(futureTask); thread.start(); // 主線程可以繼續(xù)做其他事情... System.out.println(“主線程在異步任務(wù)執(zhí)行時(shí)可以做別的工作。”); try { // 4. 在需要結(jié)果時(shí)通過FutureTask獲取 // get()方法是阻塞的會(huì)一直等待直到任務(wù)完成并返回結(jié)果 String result futureTask.get(); System.out.println(“獲取到異步結(jié)果: ” result); } catch (InterruptedException e) { // 線程在等待過程中被中斷 e.printStackTrace(); } catch (ExecutionException e) { // Callable任務(wù)執(zhí)行過程中拋出了異常會(huì)被包裝在ExecutionException中 System.out.println(“任務(wù)執(zhí)行出錯(cuò): ” e.getCause()); } } }4.3 Future的核心API與高級(jí)用法Future接口提供了對(duì)異步任務(wù)生命周期的控制get(): 獲取結(jié)果如果任務(wù)還沒完成會(huì)一直阻塞等待。get(long timeout, TimeUnit unit): 帶超時(shí)的獲取。在指定時(shí)間內(nèi)沒得到結(jié)果會(huì)拋出TimeoutException。這是防止線程無限等待、導(dǎo)致程序假死的必備技巧。isDone(): 判斷任務(wù)是否已完成包括正常完成、被取消、發(fā)生異常。cancel(boolean mayInterruptIfRunning): 嘗試取消任務(wù)。如果任務(wù)還沒開始它永遠(yuǎn)不會(huì)運(yùn)行如果任務(wù)正在運(yùn)行mayInterruptIfRunning參數(shù)決定是否向執(zhí)行線程發(fā)送中斷信號(hào)。isCancelled(): 判斷任務(wù)是否在正常完成前被取消。FutureTaskString futureTask new FutureTask(callableTask); new Thread(futureTask).start(); // 主線程先做點(diǎn)別的 TimeUnit.SECONDS.sleep(1); if (!futureTask.isDone()) { System.out.println(“任務(wù)還在進(jìn)行中...”); // 再等最多500毫秒 try { String result futureTask.get(500, TimeUnit.MILLISECONDS); System.out.println(“在超時(shí)前得到結(jié)果: ” result); } catch (TimeoutException e) { System.out.println(“等待超時(shí)決定取消任務(wù)?！?; boolean cancelled futureTask.cancel(true); // true表示嘗試中斷線程 System.out.println(“取消任務(wù)結(jié)果: ” cancelled); } }實(shí)操心得future.get()是一個(gè)阻塞調(diào)用在圖形界面GUI或高并發(fā)服務(wù)的主線程中直接使用它很容易導(dǎo)致界面卡頓或服務(wù)響應(yīng)遲緩。務(wù)必使用帶超時(shí)參數(shù)的get方法或者將get操作也放到一個(gè)后臺(tái)線程中執(zhí)行。更現(xiàn)代的做法是使用CompletableFutureJava 8它提供了非阻塞的回調(diào)機(jī)制但FutureTask是理解這一切的基礎(chǔ)。5. 三種方法的對(duì)比與選型指南了解了三種方法后我們通過一個(gè)表格來直觀對(duì)比幫你做出最佳選擇。特性維度繼承Thread類實(shí)現(xiàn)Runnable接口實(shí)現(xiàn)Callable接口 Future核心區(qū)別線程即任務(wù)任務(wù)與線程分離可返回結(jié)果、可拋異常的任務(wù)返回值無 (void run())無 (void run())有 (V call())異常處理只能在run()內(nèi)try-catch只能在run()內(nèi)try-catch可拋出Exception由調(diào)用方處理繼承限制受Java單繼承限制不靈活無限制可實(shí)現(xiàn)多個(gè)接口靈活性高無限制靈活性高資源共享較麻煩需static或傳參非常方便共享同一實(shí)例方便共享同一Callable或FutureTask代碼復(fù)雜度低但耦合高低推薦中需處理Future線程池兼容可直接提交但設(shè)計(jì)不佳天然適合提交給線程池天然適合提交給線程池適用場(chǎng)景簡(jiǎn)單Demo、特定定制絕大多數(shù)業(yè)務(wù)場(chǎng)景、異步任務(wù)需要獲取結(jié)果的異步計(jì)算、并行計(jì)算選型決策流你的任務(wù)需要返回一個(gè)結(jié)果嗎是- 毫不猶豫選擇CallableFuture。否- 進(jìn)入下一步。你的任務(wù)類還需要繼承其他類嗎是- 選擇Runnable。否- 進(jìn)入下一步。你只是寫一個(gè)臨時(shí)測(cè)試或者有特殊線程行為要重寫是- 可以考慮Thread但請(qǐng)清楚其局限性。否-默認(rèn)且推薦選擇Runnable。簡(jiǎn)單來說Runnable是通用解Callable是需返回值時(shí)的特化解而繼承Thread在大多數(shù)生產(chǎn)代碼中應(yīng)被視為遺留方式或特殊用途。6. 從手動(dòng)創(chuàng)建線程到線程池的最佳實(shí)踐演進(jìn)雖然學(xué)會(huì)了三種啟動(dòng)線程的方法但在真實(shí)的、嚴(yán)肅的生產(chǎn)環(huán)境中直接new Thread()并start()被視為一種反模式。原因如下資源消耗大創(chuàng)建和銷毀一個(gè)操作系統(tǒng)線程的成本非常高。頻繁創(chuàng)建會(huì)消耗大量系統(tǒng)資源。管理困難無法有效控制系統(tǒng)中并發(fā)線程的數(shù)量太多線程會(huì)導(dǎo)致過度切換性能下降太少則無法充分利用CPU。功能缺失缺乏統(tǒng)一的管理如定時(shí)執(zhí)行、定期執(zhí)行、線程中斷策略等。線程池ExecutorService是解決這些問題的標(biāo)準(zhǔn)答案。它預(yù)先創(chuàng)建好一批線程工作線程形成一個(gè)“池子”。當(dāng)有任務(wù)Runnable或Callable提交時(shí)池子分配一個(gè)空閑線程來執(zhí)行。任務(wù)執(zhí)行完畢后線程不銷毀而是回到池中等待下一個(gè)任務(wù)。這實(shí)現(xiàn)了線程的復(fù)用極大地降低了開銷。import java.util.concurrent.*; public class ThreadPoolDemo { public static void main(String[] args) throws ExecutionException, InterruptedException { // 1. 創(chuàng)建線程池 (核心線程數(shù)2最大線程數(shù)5空閑存活時(shí)間1秒任務(wù)隊(duì)列容量10) ExecutorService executor new ThreadPoolExecutor( 2, 5, 1L, TimeUnit.SECONDS, new ArrayBlockingQueue(10), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy() // 拒絕策略直接拋出異常 ); // 2. 提交Runnable任務(wù)無返回值 executor.execute(() - System.out.println(“執(zhí)行Runnable任務(wù): ” Thread.currentThread().getName())); // 3. 提交Callable任務(wù)有返回值 FutureString future executor.submit(() - { TimeUnit.SECONDS.sleep(1); return “Callable任務(wù)結(jié)果”; }); // 4. 獲取結(jié)果 System.out.println(“Future result: ” future.get()); // 5. 優(yōu)雅關(guān)閉線程池重要 executor.shutdown(); // 停止接收新任務(wù)等待已提交任務(wù)完成 // executor.shutdownNow(); // 嘗試立即停止所有正在執(zhí)行的任務(wù) boolean isTerminated executor.awaitTermination(5, TimeUnit.SECONDS); // 等待關(guān)閉 if (!isTerminated) { System.out.println(“仍有任務(wù)未完成強(qiáng)制關(guān)閉...”); } } }線程池配置的核心參數(shù)關(guān)系對(duì)應(yīng)網(wǎng)絡(luò)熱詞中的疑問corePoolSize核心線程數(shù)池中常駐的線程數(shù)量即使空閑也不會(huì)被回收除非設(shè)置了allowCoreThreadTimeOut。maximumPoolSize最大線程數(shù)池中允許的最大線程數(shù)。workQueue任務(wù)隊(duì)列用于存放等待執(zhí)行的任務(wù)的阻塞隊(duì)列。queueCapacity隊(duì)列大小與并發(fā)量的關(guān)系當(dāng)任務(wù)提交時(shí)如果運(yùn)行線程數(shù) corePoolSize則創(chuàng)建新線程執(zhí)行。如果運(yùn)行線程數(shù) corePoolSize則將任務(wù)放入隊(duì)列。如果隊(duì)列已滿且運(yùn)行線程數(shù) maximumPoolSize則創(chuàng)建新線程執(zhí)行。如果隊(duì)列已滿且運(yùn)行線程數(shù) maximumPoolSize則觸發(fā)拒絕策略。系統(tǒng)最大并發(fā)量估算這取決于你的系統(tǒng)資源CPU核心數(shù)、內(nèi)存、I/O和任務(wù)類型CPU密集型、I/O密集型。一個(gè)粗略的起點(diǎn)是對(duì)于CPU密集型任務(wù)線程數(shù)可設(shè)為CPU核數(shù) 1對(duì)于I/O密集型任務(wù)可設(shè)為CPU核數(shù) * (1 平均等待時(shí)間/平均計(jì)算時(shí)間)。隊(duì)列容量需要根據(jù)任務(wù)的平均處理速度和突發(fā)流量來設(shè)定起到“削峰填谷”的作用防止瞬間流量擊垮系統(tǒng)。避坑指南絕對(duì)不要使用Executors的快捷工廠方法如newFixedThreadPool,newCachedThreadPool而不了解其內(nèi)部隊(duì)列newFixedThreadPool使用無界隊(duì)列LinkedBlockingQueue任務(wù)過多會(huì)導(dǎo)致內(nèi)存耗盡newCachedThreadPool最大線程數(shù)是Integer.MAX_VALUE可能創(chuàng)建海量線程拖垮系統(tǒng)。生產(chǎn)環(huán)境務(wù)必使用ThreadPoolExecutor構(gòu)造函數(shù)根據(jù)實(shí)際情況明確指定所有參數(shù)。7. 常見問題與實(shí)戰(zhàn)排查技巧即使理解了原理在實(shí)際編碼和運(yùn)行時(shí)多線程程序依然像一座布滿暗礁的海洋。下面是我總結(jié)的一些最常見的問題和排查思路。7.1 線程安全與數(shù)據(jù)競(jìng)爭(zhēng)這是多線程編程的萬惡之源。當(dāng)多個(gè)線程未經(jīng)同步控制訪問和修改同一共享數(shù)據(jù)時(shí)就會(huì)發(fā)生數(shù)據(jù)競(jìng)爭(zhēng)導(dǎo)致結(jié)果不可預(yù)測(cè)。問題現(xiàn)象程序多次運(yùn)行結(jié)果不一致計(jì)數(shù)器的值最終小于預(yù)期如前面賣票例子可能賣出超過10張票。解決方案synchronized關(guān)鍵字最基礎(chǔ)的互斥鎖。可以修飾方法或代碼塊。// 同步代碼塊 synchronized(lockObject) { // 訪問共享資源的代碼 } // 同步實(shí)例方法鎖是當(dāng)前實(shí)例this public synchronized void increment() { ... } // 同步靜態(tài)方法鎖是當(dāng)前類的Class對(duì)象 public static synchronized void staticIncrement() { ... }java.util.concurrent.locks.Lock接口更靈活、功能更強(qiáng)的鎖如ReentrantLock。支持嘗試非阻塞獲取鎖、可中斷、公平鎖等特性。private final Lock lock new ReentrantLock(); public void safeMethod() { lock.lock(); // 獲取鎖 try { // 訪問共享資源 } finally { lock.unlock(); // 務(wù)必在finally中釋放鎖 } }使用線程安全的數(shù)據(jù)結(jié)構(gòu)ConcurrentHashMap,CopyOnWriteArrayList,AtomicInteger等。它們?cè)趦?nèi)部實(shí)現(xiàn)了高效的線程安全機(jī)制多數(shù)情況下應(yīng)優(yōu)先考慮使用它們而非自己加鎖。7.2 死鎖Deadlock兩個(gè)或更多線程互相等待對(duì)方持有的鎖導(dǎo)致所有線程都無法繼續(xù)執(zhí)行。問題現(xiàn)象程序“卡住”了日志停止輸出CPU占用率可能很低但程序無響應(yīng)。產(chǎn)生條件四個(gè)必要條件缺一不可互斥條件請(qǐng)求與保持條件不剝奪條件循環(huán)等待條件排查與解決使用JDK工具運(yùn)行程序后用jstack -l pid命令或JVisualVM等圖形工具查看線程轉(zhuǎn)儲(chǔ)Thread Dump。在輸出中搜索“deadlock”關(guān)鍵詞JDK通常會(huì)幫你分析并指出死鎖的線程和鎖信息。避免策略固定鎖的獲取順序所有線程都按相同的全局順序例如按對(duì)象的哈希值排序申請(qǐng)鎖。使用帶超時(shí)的鎖如Lock.tryLock(long time, TimeUnit unit)獲取不到鎖一段時(shí)間后放棄并釋放自己已持有的鎖。降低鎖的粒度盡量只鎖住必要的共享數(shù)據(jù)而不是大段代碼或整個(gè)對(duì)象。7.3 線程間協(xié)作wait(), notify(), notifyAll()當(dāng)線程需要等待某個(gè)條件滿足時(shí)如生產(chǎn)者-消費(fèi)者模型需要使用Object類的這組方法。它們必須在synchronized同步塊內(nèi)調(diào)用。public class ProducerConsumer { private final QueueString queue new LinkedList(); private final int MAX_SIZE 5; private final Object lock new Object(); public void produce(String item) throws InterruptedException { synchronized (lock) { while (queue.size() MAX_SIZE) { // 必須用while不能用if防止虛假喚醒 lock.wait(); // 釋放lock鎖并等待 } queue.offer(item); System.out.println(“生產(chǎn): ” item); lock.notifyAll(); // 通知所有等待的消費(fèi)者線程 } } public String consume() throws InterruptedException { synchronized (lock) { while (queue.isEmpty()) { lock.wait(); } String item queue.poll(); System.out.println(“消費(fèi): ” item); lock.notifyAll(); // 通知生產(chǎn)者線程 return item; } } }關(guān)鍵細(xì)節(jié)判斷條件時(shí)必須使用while循環(huán)而不是if語句。這是因?yàn)榇嬖凇疤摷賳拘选眘purious wakeup——線程可能在沒有被notify的情況下從wait()中返回。用while可以確保被喚醒后再次檢查條件是否真正滿足。7.4 內(nèi)存可見性與volatile關(guān)鍵字由于Java內(nèi)存模型JMM和CPU緩存的存在一個(gè)線程對(duì)共享變量的修改可能不會(huì)立即被其他線程看到。問題現(xiàn)象一個(gè)線程修改了boolean flag false為true但另一個(gè)線程卻一直讀不到變化導(dǎo)致循環(huán)無法退出。解決方案使用volatile關(guān)鍵字修飾變量volatile保證了變量的可見性一個(gè)線程的修改能立刻被其他線程看到和有序性防止指令重排序但不保證原子性復(fù)合操作仍需同步。private volatile boolean running true; public void stop() { running false; // 寫操作對(duì)其他線程立即可見 } public void run() { while (running) { // 讀操作總能讀到最新值 // do work } }使用synchronized或Lock鎖的釋放和獲取會(huì)隱式地觸發(fā)內(nèi)存屏障保證可見性。使用Atomic類如AtomicBoolean它內(nèi)部使用了volatile和CAS操作既保證了可見性又保證了簡(jiǎn)單操作的原子性。7.5 資源管理與線程中斷線程可能因?yàn)镮/O阻塞、鎖等待、sleep()等原因而處于非運(yùn)行狀態(tài)。正確的中斷和關(guān)閉線程是良好編程習(xí)慣的一部分。正確的中斷響應(yīng)Thread.interrupt()方法只是給線程設(shè)置一個(gè)中斷標(biāo)志位。線程需要自己檢查這個(gè)標(biāo)志并做出響應(yīng)。public class InterruptibleTask implements Runnable { Override public void run() { // 正確做法定期檢查中斷狀態(tài) while (!Thread.currentThread().isInterrupted()) { try { // 如果任務(wù)中有可中斷的阻塞調(diào)用如Thread.sleep, Object.wait, BlockingQueue.take // 這些方法在收到中斷信號(hào)時(shí)會(huì)拋出InterruptedException TimeUnit.SECONDS.sleep(1); // ... 執(zhí)行工作 } catch (InterruptedException e) { // 捕獲到InterruptedException后中斷狀態(tài)會(huì)被清除 System.out.println(“任務(wù)被中斷準(zhǔn)備退出。”); // 恢復(fù)中斷狀態(tài)這是一個(gè)重要技巧讓調(diào)用者知道發(fā)生了中斷 Thread.currentThread().interrupt(); break; // 退出循環(huán) } } System.out.println(“線程安全結(jié)束?！?; } }關(guān)閉線程池如前所述務(wù)必調(diào)用shutdown()或shutdownNow()來優(yōu)雅關(guān)閉線程池否則JVM可能無法正常退出。多線程編程的復(fù)雜性要求我們不僅要知道如何啟動(dòng)線程更要深刻理解其背后的并發(fā)原理、潛在陷阱和最佳實(shí)踐。從最基本的三種啟動(dòng)方式入手逐步深入到線程池、鎖、原子變量等并發(fā)工具最終構(gòu)建出健壯、高效的多線程應(yīng)用這是一個(gè)Java開發(fā)者成長的必經(jīng)之路。每一次踩坑和解決問題的經(jīng)歷都會(huì)讓你對(duì)“并發(fā)”二字的理解更加深刻。