異步處理FutureTask實例

異步處理FutureTask實例在Web應(yīng)?前端，AJAX有同步和異步處理，異步可以避免阻塞。在WEB后端?般業(yè)務(wù)應(yīng)??多為同步處理，但也有?些需要異步處理的場合，?如A系統(tǒng)調(diào)B系統(tǒng)接?I，但B系統(tǒng)處理時間很長，這時，A系統(tǒng)主線程不能?直阻塞等待，可以使?異步處理。即先調(diào)?接?I，隨即做后?的處理，等B系統(tǒng)返回值時再進?返回后處理。時序為：A:invokeIA:dootherthingB：處理完成，返回值A(chǔ)：根據(jù)接?返回值進?后處理1、代碼例?：packagecom.hf.test;importjava.util.HashMap;importjava.util.Map;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.FutureTask;importcom.xxx.framework.po.ResponseResult;publicclassFutureTest{Map<String,Object>params=newHashMap<String,Object>();ExecutorServiceexecutorService=Executors.newFixedThreadPool(3);publicvoidtest1(){params.put("clsId","clsId-001");params.put("ids","001,002,003,004");FutureTask<ResponseResult>futureTask=newFutureTask<>(newMyTask(params));executorService.submit(futureTask);executorService.submit(newMonitorTask(futureTask));executorService.submit(getCollectJob(futureTask));System.out.println("HERE");}/***返回收集?作*@paramfutureTask*@return*/publicRunnablegetCollectJob(finalFutureTask<ResponseResult>futureTask){returnnewRunnable(){publicvoidrun(){while(true){try{Thread.sleep(100);if(futureTask.isDone()){ResponseResultresp=futureTask.get();System.out.println("2返回值："+resp.getData());break;}

}System.out.println("2Notfinished.");}catch(Exceptione){e.printStackTrace();}}}};}/***關(guān)閉線程池*/publicvoidcloseThreadPool(){executorService.shutdown();}/***測試主??*@paramargs*/publicstaticvoidmain(String[]args){FutureTestft=newFutureTest();ft.test1();System.out.println("Dootherthings...");ft.closeThreadPool();}}程序說明：這?采?的模式是調(diào)?接?和收集結(jié)果2條線，分別?不同的線程來執(zhí)?。調(diào)?接?線程sumit后，收集線程隨即開始?作，每隔100ms查詢?遍返回狀態(tài)，若接?返回，則打印返回值，否則?直打印“NOTFINISHED”。2、例?2若需要處理復(fù)雜的情形，如使?回調(diào)、傳?參數(shù)處理返回結(jié)果，則可參考下?的例?。

packagecom.hf.test;importjava.util.HashMap;importjava.util.Map;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.FutureTask;importcom.xxx.framework.po.ResponseResult;publicclassFutureTest2{Map<String,Object>initParams=newHashMap<String,Object>();ExecutorServiceexecutorService=Executors.newFixedThreadPool(3);publicvoidtest1(){initParams.put("clsId","clsId-001");initParams.put("ids","001,002,003,004");MyCallbackmyCallback=newMyCallback(initParams);FutureTask<ResponseResult>futureTask=newFutureTask<>(newMyTask2(myCallback));executorService.submit(futureTask);System.out.println("HERE");}/***關(guān)閉線程池*/publicvoidcloseThreadPool(){executorService.shutdown();}/***測試主??*@paramargs*/publicstaticvoidmain(String[]args){FutureTest2ft=newFutureTest2();ft.test1();System.out.println("Dootherthings...");ft.closeThreadPool();}}回調(diào)處理類：

packagecom.hf.test;importjava.util.HashMap;importjava.util.Map;importcom.xxx.framework.po.ResponseResult;publicclassMyCallback{Map<String,Object>initParams=newHashMap<String,Object>();publicMyCallback(Map<String,Object>initParams){this.initParams=initParams;}publicResponseResultdoSomething(Map<String,Object>params){System.out.println("HERE:"+params);Stringresult="Foundparampwid:"+params.get("pwid")+",state:"+params.get("state");System.out.println("異步線程處理完成,結(jié)果："+result);returnResponseResult.successResult("異步線程處理完成,結(jié)果："+result);}}異步任務(wù)類：packagecom.hf.test;importjava.util.HashMap;importjava.util.Map;importjava.util.concurrent.Callable;importcom.xxx.framework.po.ResponseResult;publicclassMyTask2implementsCallable<ResponseResult>{MyCallbackmyCallback=null;publicMyTask2(MyCallbackmyCallback){this.myCallback=myCallback;}@OverridepublicResponseResultcall()throwsException{System.out.println("Startprocessing...");//模擬處理過程Thread.sleep(10*1000);Map<String,Object>params=newHashMap<String,Object>();params.put("pwid","pwid-001");params.put("state","已退回");//模