Java FutureTask類使用案例解析
FutureTask一個可取消的異步計算,F(xiàn)utureTask 實現(xiàn)了Future的基本方法,提空 start cancel 操作,可以查詢計算是否已經(jīng)完成,并且可以獲取計算的結(jié)果。結(jié)果只可以在計算完成之后獲取,get方法會阻塞當計算沒有完成的時候,一旦計算已經(jīng)完成,那么計算就不能再次啟動或是取消。
一個FutureTask 可以用來包裝一個 Callable 或是一個runnable對象。因為FurtureTask實現(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實現(xiàn)了RunnableFuture接口,RunnableFuture接口是Runnable和Future的綜合體。
作為一個Future,F(xiàn)utureTask可以執(zhí)行異步計算,可以查看異步程序是否執(zhí)行完畢,并且可以開始和取消程序,并取得程序最終的執(zhí)行結(jié)果。
除此之外,F(xiàn)utureTask還提供了一個runAndReset()的方法, 該方法可以運行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);方法進行轉(zhuǎn)換的。
以Runnable運行
既然是一個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í)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot實現(xiàn)的Mongodb管理工具使用解析
這篇文章主要介紹了SpringBoot實現(xiàn)的Mongodb管理工具使用解析,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-09-09springboot使用RedisRepository操作數(shù)據(jù)的實現(xiàn)
本文主要介紹了springboot使用RedisRepository操作數(shù)據(jù)的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05自定義spring mvc的json視圖實現(xiàn)思路解析
這篇文章主要介紹了自定義spring mvc的json視圖的實現(xiàn)思路解析,本文給大家介紹的非常詳細,具有參考借鑒價值,需要的朋友可以參考下2017-12-12Java高效實現(xiàn)excel轉(zhuǎn)pdf(支持帶圖片的轉(zhuǎn)換)
這篇文章主要為大家詳細介紹了如何用java實現(xiàn)excel轉(zhuǎn)pdf文件,并且支持excel單元格中帶有圖片的轉(zhuǎn)換,文中的示例代碼講解詳細,需要的可以參考下2024-01-01淺談Java虛擬機對內(nèi)部鎖的四種優(yōu)化方式
這篇文章主要介紹了淺談Java虛擬機對內(nèi)部鎖的四種優(yōu)化方式,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-10-10Java利用Dijkstra和Floyd分別求取圖的最短路徑
本文主要介紹了圖的最短路徑的概念,并分別利用Dijkstra算法和Floyd算法求取最短路徑,最后提供了基于鄰接矩陣和鄰接表的圖對兩種算法的Java實現(xiàn)。需要的可以參考一下2022-01-01