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

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

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

讓我們首先定義將執(zhí)行實際任務(wù)的類：

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可以使用任何返回類型，因此您的任務(wù)可以返回所需的任何信息。

現(xiàn)在，我們可以使用線程池ExecutorService發(fā)送電子郵件，并且由于我們的任務(wù)是作為Callable實現(xiàn)的，因此對于提交給執(zhí)行的每個新任務(wù)，我們都會獲得Future參考。 請注意，我們將使用直接構(gòu)造函數(shù)而不是Executors中的實用程序方法來創(chuàng)建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();}} }

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

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

這種基礎(chǔ)結(jié)構(gòu)不僅易于使用，而且還可以促進關(guān)注點的清晰分離，從而在調(diào)度程序和實際任務(wù)之間提供了預(yù)定義的通信機制。

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

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。