在 Java 多執行緒應用程式中，如何確保所有執行緒在繼續之前完成？

在 Java 中協調執行緒執行

在多執行緒應用程式中，通常需要同步多個執行緒之間的任務完成。當一個執行緒的執行結果取決於另一個執行緒的完成時尤其如此。在這種情況下，讓我們探討如何確定 Java 程式中的所有執行緒何時完成其工作。

問題陳述：

您有一個同時具有五個執行緒的應用程式從網路檢索資料並填充共用緩衝區類別中的五個不同欄位。您的目標是在所有執行緒完成其任務後驗證緩衝區資料並將其儲存在資料庫中。關鍵的挑戰在於確定所有執行緒完成執行的時刻。

解決方案：

管理執行緒池的一種有效方法是使用 ExecutorService，它提供了一種建立和管理執行緒的便捷方法。以下是實作此解決方案的方法：

ExecutorService es = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    es.execute(new Runnable() { /* Implement your task */ });
}
es.shutdown();
boolean finished = es.awaitTermination(1, TimeUnit.MINUTES);
// All tasks have finished or the time has been reached.

在此程式碼片段中，我們首先使用 Executors.newCachedThreadPool() 方法建立一個 ExecutorService。這將創建一個線程池，該線程池根據提交的任務數量動態調整其大小。然後，我們使用execute()方法向執行器服務提交五個任務。

提交所有任務後，我們呼叫shutdown()方法來指示不再向執行器服務提交任何任務。之後，我們以指定的逾時（本例為 1 分鐘）呼叫awaitTermination() 方法。此方法會阻塞目前線程，直到所有任務完成或達到逾時。

如果所有任務在逾時之前完成，則 finish 變數將設為 true，否則設為 false。然後，您可以根據finished的值執行必要的驗證和資料庫儲存操作。

透過利用ExecutorService和awaitTermination()方法，您可以有效地等待，直到Java程式中的所有執行緒完成其工作然後繼續您的應用程式中的後續步驟。

以上是在 Java 多執行緒應用程式中，如何確保所有執行緒在繼續之前完成？的詳細內容。更多資訊請關注PHP中文網其他相關文章！