Java并发性-任务反馈
例如,假設一個應用程序必須發送電子郵件批處理,除了使用多線程機制外,您還想知道成功發送了多少預期的電子郵件,以及在實際發送過程中,整個郵件的實時進度批量。
為了實現帶有反饋的這種多線程,我們可以使用 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并发性-任务反馈的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 对JavaFX Mobile应用程序进行
- 下一篇: 奉化属于哪个市(浙江省宁波奉化区)