亚洲免费在线视频-亚洲啊v-久久免费精品视频-国产精品va-看片地址-成人在线视频网

您的位置:首頁技術(shù)文章
文章詳情頁

Java FutureTask類使用案例解析

瀏覽:120日期:2022-09-02 13:07:19

FutureTask一個可取消的異步計(jì)算,F(xiàn)utureTask 實(shí)現(xiàn)了Future的基本方法,提空 start cancel 操作,可以查詢計(jì)算是否已經(jīng)完成,并且可以獲取計(jì)算的結(jié)果。結(jié)果只可以在計(jì)算完成之后獲取,get方法會阻塞當(dāng)計(jì)算沒有完成的時候,一旦計(jì)算已經(jīng)完成,那么計(jì)算就不能再次啟動或是取消。

一個FutureTask 可以用來包裝一個 Callable 或是一個runnable對象。因?yàn)镕urtureTask實(shí)現(xiàn)了Runnable方法,所以一個 FutureTask可以提交(submit)給一個Excutor執(zhí)行(excution).

FutureTask是java 5引入的一個類,從名字可以看出來FutureTask既是一個Future,又是一個Task。

我們看下FutureTask的定義:

public class FutureTask<V> implements RunnableFuture<V> { ...}public interface RunnableFuture<V> extends Runnable, Future<V> { /** * Sets this Future to the result of its computation * unless it has been cancelled. */ void run();}

FutureTask實(shí)現(xiàn)了RunnableFuture接口,RunnableFuture接口是Runnable和Future的綜合體。

作為一個Future,F(xiàn)utureTask可以執(zhí)行異步計(jì)算,可以查看異步程序是否執(zhí)行完畢,并且可以開始和取消程序,并取得程序最終的執(zhí)行結(jié)果。

除此之外,F(xiàn)utureTask還提供了一個runAndReset()的方法, 該方法可以運(yùn)行task并且重置Future的狀態(tài)。

Callable和Runnable的轉(zhuǎn)換我們知道Callable是有返回值的,而Runnable是沒有返回值的。Executors提供了很多有用的方法,將Runnable轉(zhuǎn)換為Callable:

public static <T> Callable<T> callable(Runnable task, T result) { if (task == null) throw new NullPointerException(); return new RunnableAdapter<T>(task, result); }

FutureTask內(nèi)部包含一個Callable,并且可以接受Callable和Runnable作為構(gòu)造函數(shù):

public FutureTask(Callable<V> callable) { if (callable == null) throw new NullPointerException(); this.callable = callable; this.state = NEW; // ensure visibility of callable } public FutureTask(Runnable runnable, V result) { this.callable = Executors.callable(runnable, result); this.state = NEW; // ensure visibility of callable }

它的內(nèi)部就是調(diào)用了Executors.callable(runnable, result);方法進(jìn)行轉(zhuǎn)換的。

以Runnable運(yùn)行

既然是一個Runnable,那么FutureTask就可以以線程的方式執(zhí)行,我們來看一個例子:

@Test public void convertRunnableToCallable() throws ExecutionException, InterruptedException { FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() { @Override public Integer call() throws Exception {log.info('inside callable future task ...');return 0; } }); Thread thread= new Thread(futureTask); thread.start(); log.info(futureTask.get().toString()); }

上面例子是以單個線程來執(zhí)行的,同樣我們也可以將FutureTask提交給線程池來執(zhí)行:

@Test public void workWithExecutorService() throws ExecutionException, InterruptedException { FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() { @Override public Integer call() throws Exception {log.info('inside futureTask');return 1; } }); ExecutorService executor = Executors.newCachedThreadPool(); executor.submit(futureTask); executor.shutdown(); log.info(futureTask.get().toString()); }

本文的例子可參考https://github.com/ddean2009/learn-java-concurrency/tree/master/futureTask

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Java
相關(guān)文章:
主站蜘蛛池模板: 超91精品手机国产在线 | 欧美精品一区二区精品久久 | 久久国产精品最新一区 | 美女张开腿让人桶 | 成 人免费va视频 | 国产精品久久不卡日韩美女 | 在线不卡国产 | 亚洲女人被黑人猛躁进女人 | 免费韩国一级毛片 | 久久曰视频 | 视频一区二区三区在线 | 麻豆视频一区 | 国产一级在线观看视频 | 日本高清在线中文字幕网 | 欧美日本一道高清二区三区 | 日韩在线免费视频 | 国产日韩久久久精品影院首页 | 免费一级毛片正在播放 | 国产免费网 | 一区二区三区免费高清视频 | 午夜精品久视频在线观看 | 成人精品在线观看 | 国产成人免费观看在线视频 | 国产精品系列在线 | 久久成人18免费网站 | 手机看成人免费大片 | 四虎免费大片aⅴ入口 | 久久久久久国产精品免费免 | 日本亚州视频在线八a | 日本在线加勒比 | 欧美极品在线视频 | 韩国三级日本三级香港三级黄 | 在线观看黄网视频免费播放 | 亚洲国产精品看片在线观看 | 欧美高清在线精品一区 | 日本高清色www | 爱福利极品盛宴 | 久久精品免费观看久久 | gv手机在线观看 | 久久黄色一级视频 | 在线一区二区观看 |