您好,登錄后才能下訂單哦!
本篇文章為大家展示了 Future接口如何在Java項目中使用,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
java Future 接口使用方法詳解
在Java中,如果需要設(shè)定代碼執(zhí)行的最長時間,即超時,可以用Java線程池ExecutorService類配合Future接口來實(shí)現(xiàn)。 Future接口是Java標(biāo)準(zhǔn)API的一部分,在java.util.concurrent包中。Future接口是Java線程Future模式的實(shí)現(xiàn),可以來進(jìn)行異步計算。
Future模式可以這樣來描述:我有一個任務(wù),提交給了Future,F(xiàn)uture替我完成這個任務(wù)。期間我自己可以去做任何想做的事情。一段時間之后,我就便可以從Future那兒取出結(jié)果。就相當(dāng)于下了一張訂貨單,一段時間后可以拿著提訂單來提貨,這期間可以干別的任何事情。其中Future 接口就是訂貨單,真正處理訂單的是Executor類,它根據(jù)Future接口的要求來生產(chǎn)產(chǎn)品。
Future接口提供方法來檢測任務(wù)是否被執(zhí)行完,等待任務(wù)執(zhí)行完獲得結(jié)果,也可以設(shè)置任務(wù)執(zhí)行的超時時間。這個設(shè)置超時的方法就是實(shí)現(xiàn)Java程序執(zhí)行超時的關(guān)鍵。
Future接口是一個泛型接口,嚴(yán)格的格式應(yīng)該是Future<V>,其中V代表了Future執(zhí)行的任務(wù)返回值的類型。 Future接口的方法介紹如下:
Future的實(shí)現(xiàn)類有java.util.concurrent.FutureTask<V>即 javax.swing.SwingWorker<T,V>。通常使用FutureTask來處理我們的任務(wù)。FutureTask類同時又實(shí)現(xiàn)了Runnable接口,所以可以直接提交給Executor執(zhí)行。使用FutureTask實(shí)現(xiàn)超時執(zhí)行的代碼如下:
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = new FutureTask<String>(new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類型為String,可以為任意類型 }}); executor.execute(future); //在這里可以做別的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果,同時設(shè)置超時執(zhí)行時間為5秒。同樣可以用future.get(),不設(shè)置執(zhí)行超時時間取得結(jié)果 } catch (InterruptedException e) { futureTask.cancel(true); } catch (ExecutionException e) { futureTask.cancel(true); } catch (TimeoutException e) { futureTask.cancel(true); } finally { executor.shutdown(); }
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = new FutureTask<String>(new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類型為String,可以為任意類型 }}); executor.execute(future); //在這里可以做別的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果,同時設(shè)置超時執(zhí)行時間為5秒。同樣可以用future.get(),不設(shè)置執(zhí)行超時時間取得結(jié)果 } catch (InterruptedException e) { futureTask.cancel(true); } catch (ExecutionException e) { futureTask.cancel(true); } catch (TimeoutException e) { futureTask.cancel(true); } finally { executor.shutdown(); }
不直接構(gòu)造Future對象,也可以使用ExecutorService.submit方法來獲得Future對象,submit方法即支持以 Callable接口類型,也支持Runnable接口作為參數(shù),具有很大的靈活性。使用示例如下:
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = executor.submit( new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類型為String,可以為任意類型 }}); //在這里可以做別的任何事情 //同上面取得結(jié)果的代碼
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTask<String> future = executor.submit( new Callable<String>() {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類型為String,可以為任意類型 }}); //在這里可以做別的任何事情 //同上面取得結(jié)果的代碼
利用Future接口實(shí)現(xiàn)程序執(zhí)行超時大致用法就這么多,改天需要研究下Future接口的內(nèi)部實(shí)現(xiàn),特別是設(shè)定執(zhí)行超時的實(shí)現(xiàn)。
上述內(nèi)容就是 Future接口如何在Java項目中使用,你們學(xué)到知識或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識儲備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。