使用 Future 時如何有效處理錯誤和提前終止？

等待 Future 清單的提前終止

在處理 future 表示的非同步任務時，等待所有處理完成通常至關重要。完成或發生錯誤。然而，即使在發生錯誤後，不必要地等待所有任務完成也是不可取的。

要解決這個問題，請考慮以下步驟：

1. 利用a CompletionService：

   • 建立一個以接收可用的future。
   • 使用封裝處理的 Callable 物件提交任務。

2. 依序監視 Future：

   • 使用循環迭代從 CompletionService 接收到的 future。
   • 嘗試擷取下列結果每個 future 都使用 Future.get()。
   • 如果任何 future 拋出異常，請設定標誌以指示發生了錯誤。

3. 取消剩餘任務：

   • 一旦檢測到錯誤，請取消所有剩餘任務，以防止不必要的等待。

這裡是一個範例示範了這個方法：

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = 
       new ExecutorCompletionService<SomeResult>(executor);

// 4 tasks
for(int i = 0; i < 4; i++) {
   completionService.submit(new Callable<SomeResult>() {
       public SomeResult call() {
           // Processing code
           return result;
       }
   });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
      Future<SomeResult> resultFuture = completionService.take(); // Blocks until available
      try {
         SomeResult result = resultFuture.get();
         received ++;
         // Process the result
      }
      catch(Exception e) {
         // Log or handle the error
         errors = true;
      }

      if (errors) {
         // Cancel any remaining tasks
         executor.shutdown();
         break;
      }
}</code>

以上是使用 Future 時如何有效處理錯誤和提前終止？的詳細內容。更多資訊請關注PHP中文網其他相關文章！