本篇文章為大家展示了 Future接口如何在Java項(xiàng)目中使用,內(nèi)容簡(jiǎn)明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。
創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括久治網(wǎng)站建設(shè)、久治網(wǎng)站制作、久治網(wǎng)頁(yè)制作以及久治網(wǎng)絡(luò)營(yíng)銷(xiāo)策劃等。多年來(lái),我們專(zhuān)注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,久治網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到久治省份的部分城市,未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!
java Future 接口使用方法詳解
在Java中,如果需要設(shè)定代碼執(zhí)行的最長(zhǎng)時(shí)間,即超時(shí),可以用Java線程池ExecutorService類(lèi)配合Future接口來(lái)實(shí)現(xiàn)。 Future接口是Java標(biāo)準(zhǔn)API的一部分,在java.util.concurrent包中。Future接口是Java線程Future模式的實(shí)現(xiàn),可以來(lái)進(jìn)行異步計(jì)算。
Future模式可以這樣來(lái)描述:我有一個(gè)任務(wù),提交給了Future,F(xiàn)uture替我完成這個(gè)任務(wù)。期間我自己可以去做任何想做的事情。一段時(shí)間之后,我就便可以從Future那兒取出結(jié)果。就相當(dāng)于下了一張訂貨單,一段時(shí)間后可以拿著提訂單來(lái)提貨,這期間可以干別的任何事情。其中Future 接口就是訂貨單,真正處理訂單的是Executor類(lèi),它根據(jù)Future接口的要求來(lái)生產(chǎn)產(chǎn)品。
Future接口提供方法來(lái)檢測(cè)任務(wù)是否被執(zhí)行完,等待任務(wù)執(zhí)行完獲得結(jié)果,也可以設(shè)置任務(wù)執(zhí)行的超時(shí)時(shí)間。這個(gè)設(shè)置超時(shí)的方法就是實(shí)現(xiàn)Java程序執(zhí)行超時(shí)的關(guān)鍵。
Future接口是一個(gè)泛型接口,嚴(yán)格的格式應(yīng)該是Future
Future的實(shí)現(xiàn)類(lèi)有java.util.concurrent.FutureTask
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTaskfuture = new FutureTask (new Callable () {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類(lèi)型為String,可以為任意類(lèi)型 }}); executor.execute(future); //在這里可以做別的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果,同時(shí)設(shè)置超時(shí)執(zhí)行時(shí)間為5秒。同樣可以用future.get(),不設(shè)置執(zhí)行超時(shí)時(shí)間取得結(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(); FutureTaskfuture = new FutureTask (new Callable () {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類(lèi)型為String,可以為任意類(lèi)型 }}); executor.execute(future); //在這里可以做別的任何事情 try { result = future.get(5000, TimeUnit.MILLISECONDS); //取得結(jié)果,同時(shí)設(shè)置超時(shí)執(zhí)行時(shí)間為5秒。同樣可以用future.get(),不設(shè)置執(zhí)行超時(shí)時(shí)間取得結(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對(duì)象,也可以使用ExecutorService.submit方法來(lái)獲得Future對(duì)象,submit方法即支持以 Callable接口類(lèi)型,也支持Runnable接口作為參數(shù),具有很大的靈活性。使用示例如下:
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTaskfuture = executor.submit( new Callable () {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類(lèi)型為String,可以為任意類(lèi)型 }}); //在這里可以做別的任何事情 //同上面取得結(jié)果的代碼
ExecutorService executor = Executors.newSingleThreadExecutor(); FutureTaskfuture = executor.submit( new Callable () {//使用Callable接口作為構(gòu)造參數(shù) public String call() { //真正的任務(wù)在這里執(zhí)行,這里的返回值類(lèi)型為String,可以為任意類(lèi)型 }}); //在這里可以做別的任何事情 //同上面取得結(jié)果的代碼
利用Future接口實(shí)現(xiàn)程序執(zhí)行超時(shí)大致用法就這么多,改天需要研究下Future接口的內(nèi)部實(shí)現(xiàn),特別是設(shè)定執(zhí)行超時(shí)的實(shí)現(xiàn)。
上述內(nèi)容就是 Future接口如何在Java項(xiàng)目中使用,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。