日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問(wèn) 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

ExecutorService——shutdown方法和awaitTermination方法

發(fā)布時(shí)間:2023/12/6 编程问答 30 豆豆
生活随笔 收集整理的這篇文章主要介紹了 ExecutorService——shutdown方法和awaitTermination方法 小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

ExecutorService的關(guān)閉
shutdown和awaitTermination為接口ExecutorService定義的兩個(gè)方法,一般情況配合使用來(lái)關(guān)閉線程池。

方法簡(jiǎn)介
shutdown方法:平滑的關(guān)閉ExecutorService,當(dāng)此方法被調(diào)用時(shí),ExecutorService停止接收新的任務(wù)并且等待已經(jīng)提交的任務(wù)(包含提交正在執(zhí)行和提交未執(zhí)行)執(zhí)行完成。當(dāng)所有提交任務(wù)執(zhí)行完畢,線程池即被關(guān)閉。

awaitTermination方法:接收人timeout和TimeUnit兩個(gè)參數(shù),用于設(shè)定超時(shí)時(shí)間及單位。當(dāng)?shù)却^(guò)設(shè)定時(shí)間時(shí),會(huì)監(jiān)測(cè)ExecutorService是否已經(jīng)關(guān)閉,若關(guān)閉則返回true,否則返回false。一般情況下會(huì)和shutdown方法組合使用。

具體實(shí)例
普通任務(wù)處理類:

package com.secbro.test.thread;import java.util.concurrent.Callable;/*** @author zhuzhisheng* @Description* @date on 2016/6/1.*/ public class Task implements Callable{@Overridepublic Object call() throws Exception {System.out.println("普通任務(wù)");return null;} }

長(zhǎng)時(shí)間任務(wù)處理類:

package com.secbro.test.thread;import java.util.concurrent.Callable; import java.util.concurrent.TimeUnit;/*** @author zhuzhisheng* @Description* @date on 2016/6/1.*/ public class LongTask implements Callable{@Overridepublic Object call() throws Exception {System.out.println("長(zhǎng)時(shí)間任務(wù)");TimeUnit.SECONDS.sleep(5);return null;} }

測(cè)試類:

package com.secbro.test.thread;import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit;/*** @author zhuzhisheng* @Description* @date on 2016/6/1.*/ public class TestShutDown {public static void main(String[] args) throws InterruptedException{ScheduledExecutorService service = Executors.newScheduledThreadPool(4);service.submit(new Task());service.submit(new Task());service.submit(new LongTask());service.submit(new Task());service.shutdown();while (!service.awaitTermination(1, TimeUnit.SECONDS)) {System.out.println("線程池沒(méi)有關(guān)閉");}System.out.println("線程池已經(jīng)關(guān)閉");}}

輸出結(jié)果為:

普通任務(wù) 普通任務(wù) 長(zhǎng)時(shí)間任務(wù) 普通任務(wù) 線程池沒(méi)有關(guān)閉 線程池沒(méi)有關(guān)閉 線程池沒(méi)有關(guān)閉 線程池沒(méi)有關(guān)閉 線程池已經(jīng)關(guān)閉

?

總結(jié)

以上是生活随笔為你收集整理的ExecutorService——shutdown方法和awaitTermination方法的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò),歡迎將生活随笔推薦給好友。