從我 上一篇 關于java.util.concurrent包的 文章 的結尾處 摘下來 ，這很有趣，有時甚至必須在并發任務啟動后從它們那里獲得反饋。

例如，假設一個應用程序必須發送電子郵件批處理，除了使用多線程機制外，您還想知道成功發送了多少預期的電子郵件，以及在實際發送過程中，整個郵件的實時進度批量。

為了實現帶有反饋的這種多線程，我們可以使用 Callable 接口。 該接口的工作方式與 Runnable 大致相同 ，但是執行方法（call（））返回的值應反映所執行計算的結果。

讓我們首先定義將執行實際任務的類：

package com.ricardozuasti;import java.util.concurrent.Callable;public class FictionalEmailSender implements Callable<Boolean> {public FictionalEmailSender (String to, String subject, String body){this.to = to;this.subject = subject;this.body = body;}@Overridepublic Boolean call() throws InterruptedException {// Simulate that sending the email takes between 0 and 0.5 secondsThread.sleep(Math.round(Math.random()* 0.5 * 1000));// Lets say we have an 80% chance of successfully sending our emailif (Math.random()>0.2){return true;} else {return false;}}private String to;private String subject;private String body; }

請注意， Callable可以使用任何返回類型，因此您的任務可以返回所需的任何信息。

現在，我們可以使用線程池ExecutorService發送電子郵件，并且由于我們的任務是作為Callable實現的，因此對于提交給執行的每個新任務，我們都會獲得Future參考。 請注意，我們將使用直接構造函數而不是Executors中的實用程序方法來創建ExecutorService ，這是因為使用特定類（ ThreadPoolExecutor ）提供了一些方便的方法（在ExecutorService接口中不存在）。

package com.ricardozuasti;import java.util.ArrayList; import java.util.List; import java.util.concurrent.Future; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit;public class Concurrency2 {public static void main(String[] args) {try {ThreadPoolExecutor executor = new ThreadPoolExecutor(30, 30, 1, TimeUnit.SECONDS,new LinkedBlockingQueue());List<Future<Boolean>> futures = new ArrayList<Future<Boolean>>(9000);// Lets spam every 4 digit numeric user on that silly domainfor (int i = 1000; i < 10000; i++) {futures.add(executor.submit(new FictionalEmailSender(i + '@wesellnumericusers.com','Knock, knock, Neo', 'The Matrix has you...')));}// All tasks have been submitted, wen can begin the shutdown of our executorSystem.out.println('Starting shutdown...');executor.shutdown();// Every second we print our progresswhile (!executor.isTerminated()) {executor.awaitTermination(1, TimeUnit.SECONDS);int progress = Math.round((executor.getCompletedTaskCount() * 100) /executor.getTaskCount());System.out.println(progress + '% done (' + executor.getCompletedTaskCount() +' emails have been sent).');}// Now that we are finished sending all the emails, we can review the futures// and see how many were successfully sentint errorCount = 0;int successCount = 0;for (Future<Boolean> future : futures) {if (future.get()) {successCount++;} else {errorCount++;}}System.out.println(successCount + ' emails were successfully sent, but '+ errorCount + ' failed.');} catch (Exception ex) {ex.printStackTrace();}} }

在將所有任務提交給ExecutorService之后 ，我們開始關閉它（防止提交新任務），并使用循環（在實際情況下，如果可能，您應該繼續執行其他操作）等待所有任務完成，然后進行計算并打印到目前為止每次迭代的進度。 請注意，您可以隨時存儲執行程序引用并從其他線程查詢它，以計算和報告流程進度。

最后，使用對每個提交給ExecutorService的 Callable的Future引用的集合，我們可以告知成功發送的電子郵件數量和失敗的電子郵件數量。

這種基礎結構不僅易于使用，而且還可以促進關注點的清晰分離，從而在調度程序和實際任務之間提供了預定義的通信機制。

參考： Java并發示例–在Ricardo Zuasti的博客博客中，從我們的JCG合作伙伴 Ricardo Zuasti 獲得并發任務的反饋 。

翻譯自: https://www.javacodegeeks.com/2012/06/java-concurrency-feedback-from-tasks.html

總結

以上是生活随笔為你收集整理的Java并发性-任务反馈的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。