Java - 線程合流

你好啊，未來的Java巫師们！? 今天，我們將要深入Java的線程合流的世界。如果你是編程新手，別擔心——我會一步一步引導你走過這段旅程，就像我這些年教學中為無數學生所做的那樣。所以，拿起你最喜歡的飲料，放鬆一下，讓我們一起踏上這段激動人心的冒險吧！

Java - Joining Threads

線程是什麼？

在我們跳進線程合流之前，先花點時間了解一下線程是什麼。想像你正在廚房準備一頓複雜的飯菜。你可能有一個人在切菜，另一個人在攪拌鍋裡的東西，還有一个人在佈置餐桌。每個人就像電腦程序中的一個線程，同時進行不同的任務以達成共同的目标。

在Java中，線程讓我們的程序能夠同時執行多個任務，使它們更加高效和靈敏。這就像在你的程序廚房中有多位廚師一樣！

為什麼要合流線程？

現在，讓我們來談談線程合流。想像你是我們廚房類比中的主廚。你想要確保所有準備工作都在上菜之前完成。這就是線程合流派上用場的地方。它允許一個線程（就像我們的主廚）在繼續前進之前等待另一個線程完成其執行。

如何在Java中合流線程

我們來看看如何在Java中合流線程。我們將從一個簡單的例子開始，然後再逐步建立。

示例1：基本的線程合流

public class BasicThreadJoining {
public static void main(String[] args) {
Thread thread1 = new Thread(() -> {
for (int i = 1; i <= 5; i++) {
System.out.println("Thread 1: Count " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

Thread thread2 = new Thread(() -> {
for (int i = 1; i <= 5; i++) {
System.out.println("Thread 2: Count " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

thread1.start();
thread2.start();

try {
thread1.join();
thread2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}

System.out.println("Both threads have finished counting!");
}
}

讓我們來分解一下：

我們創建兩個線程，thread1 和 thread2，每個線程從1數到5，每數一次間隔1秒。
我們使用 start() 方法啟動兩個線程。
我們在兩個線程上使用 join()，這會讓主線程等待 thread1 和 thread2 都完成它們的執行。
當兩個線程都完成後，我們打印一條消息表示它們已完成。

當你運行這個程序時，你會看到兩個線程的計數是交錯的，最後的消息只會在兩個線程都完成計數後出現。

示例2：帶有超時的合流

有時，我們不希望無限期地等待一個線程完成。Java允許我們在合流線程時指定一個超時時間。讓我們修改我們之前的例子：

public class ThreadJoiningWithTimeout {
public static void main(String[] args) {
Thread slowThread = new Thread(() -> {
for (int i = 1; i <= 10; i++) {
System.out.println("Slow Thread: Count " + i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});

slowThread.start();

try {
slowThread.join(5000); // 至多等待5秒
} catch (InterruptedException e) {
e.printStackTrace();
}

if (slowThread.isAlive()) {
System.out.println("Slow thread is still running, but we're moving on!");
} else {
System.out.println("Slow thread finished within the timeout period.");
}
}
}

在這個例子中：

我們創建一個 slowThread，從1數到10，每次計數間隔1秒。
我們使用 join(5000)，這意味著我們最多會等待5秒以讓線程完成。
在合流嘗試之後，我們使用 isAlive() 檢查線程是否仍然活著。
根據線程是否完成，我們打印一條適當的消息。

這種方法在你想確保程序不會無限期地掛起等待一個可能花費太久的線程時特別有用。

線程合流的常見方法

以下是一個便捷的表格，列出了Java中線程合流最常用的方法：

方法	描述
`join()`	等待此線程結束
`join(long millis)`	至多等待 `millis` 毫秒讓此線程結束
`join(long millis, int nanos)`	至多等待 `millis` 毫秒加上 `nanos` 納秒讓此線程結束

最佳實踐和技巧

始終處理 InterruptedException：當使用 join() 時，始終捕獲並處理 InterruptedException。如果等待的線程被中斷，則會拋出此異常。
避免死鎖：當心在循環中合流線程。例如，如果線程A等待線程B，而線程B等待線程A，你將得到一個死鎖。
明智地使用超時：當使用帶有超時的 join() 時，根據你的應用程序需求選擇一個適當的超時值。
考慮替代方案：有時，根據你的具體用例，其他同步機制如 CountDownLatch 或 CyclicBarrier 可能比 join() 更為合適。
徹底測試：多線程代碼可能很複雜。始終徹底測試你的線程合流代碼，以確保它在各種條件下都能如預期般運作。

結論

恭喜！你剛剛走出了Java線程合流世界的第一步。記住，像學習做飯一樣，掌握多線程需要練習和耐心。如果一開始沒有馬上領悟，別氣餒——繼續實驗，很快你就會像專業廚師一樣，輕鬆地編寫複雜的多線程程序！

在我們結束之際，我想起了一個學生曾經告訴我，理解線程合流後，她終於感覺自己在代碼中“指揮交響樂團”。這就是多線程的美麗之處——它讓你能夠和諧地編排多個任務。

繼續編碼，繼續學習，最重要的是，玩得開心！下次見，編程愉快！??

Credits: Image by storyset