使用多個執行緒時,協調它們的執行並確保它們在繼續之前完成任務至關重要。在此場景中,您有五個執行緒同時從 Web 取得資料並填入緩衝區類別。您的目標是驗證緩衝區中的數據,並僅在所有執行緒完成其工作時將其儲存在資料庫中。
在 Java 中實現此目的的一種有效方法是透過利用 ExecutorService,它提供了一個方便的 API 來管理執行緒池。以下是實作此方法的方法:
ExecutorService es = Executors.newCachedThreadPool(); // Submit the tasks to the executor service for (int i = 0; i < 5; i++) { es.execute(new Runnable() { // Implement your task here }); } // Shut down the executor service after submitting the tasks es.shutdown(); // Wait for all tasks to finish or for a specified timeout boolean finished = es.awaitTermination(1, TimeUnit.MINUTES); // If all tasks have finished, proceed with validation and database storage if (finished) { validateBufferData(); storeDataInDatabase(); }
透過使用awaitTermination方法,您可以阻塞主線程,直到執行程式服務中的所有任務完成或達到指定的逾時。這確保了資料驗證和資料庫儲存僅在所有執行緒完成其工作時發生。
以上是如何確保所有 Java 執行緒在繼續之前完成?的詳細內容。更多資訊請關注PHP中文網其他相關文章!