ExecutorService生命週期

2021-06-14 16:58:54 字數 4226 閱讀 6019

executorservice介面繼承了executor介面,定義了一些生命週期的方法

public inte***ce executorservice extends executor

本文,我們逐一分析裡面的每個方法。

首先,我們需要建立乙個任務**,這段任務**主要是隨機生成含有10個字元的字串

/**

* 隨機生成10個字元的字串

* @author dream-victor

* */

public class task1 implements callable

return sb.tostring();

}}

然後,我們還需要乙個長任務,這裡我們預設是沉睡10秒

/**

* 長時間任務

* * @author dream-victor

* */

public class longtask implements callable

}

ok,所有前期準備完畢,下面我們就來分析一下executorservice介面中和生命週期有關的這些方法:

1、shutdown方法:這個方法會平滑地關閉executorservice,當我們呼叫這個方法時,executorservice停止接受任何新的任務且等待已經提交的任務執行完成(已經提交的任務會分兩類:一類是已經在執行的,另一類是還沒有開始執行的),當所有已經提交的任務執行完畢後將會關閉executorservice。這裡我們先不舉例在下面舉例。

2、awaittermination方法:這個方法有兩個引數,乙個是timeout即超時時間,另乙個是unit即時間單位。這個方法會使執行緒等待timeout時長,當超過timeout時間後,會監測executorservice是否已經關閉,若關閉則返回true,否則返回false。一般情況下會和shutdown方法組合使用。例如:

executorservice service = executors.newfixedthreadpool(4);

service.submit(new task1());

service.submit(new task1());

service.submit(new longtask());

service.submit(new task1());

service.shutdown();

while (!service.awaittermination(1, timeunit.seconds))

system.out.println("執行緒池已經關閉");

這段**中,我們在第三次提交了乙個長任務,這個任務將執行10秒沉睡,緊跟著執行了一次shutdown()方法,假設:這時executorservice被立即關閉,下面呼叫service.awaittermination(1, timeunit.seconds)方法時應該返回true,程式執行結果應該只會列印出:「執行緒池已經關閉」。但是,真實的執行結果如下:

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池沒有關閉

執行緒池已經關閉

這說明我們假設錯誤,service.awaittermination(1, timeunit.seconds)每隔一秒監測一次executorservice的關閉情況,而長任務正好需要執行10秒,因此會在前9秒監測時executorservice為未關閉狀態,而在第10秒時已經關閉,因此第10秒時輸出:執行緒池已經關閉。這也驗證了shutdown方法關閉executorservice的條件。

3、shutdownnow方法:這個方法會強制關閉executorservice,它將取消所有執行中的任務和在工作佇列中等待的任務,這個方法返回乙個list列表,列表中返回的是等待在工作佇列中的任務。例如:

executorservice service = executors.newfixedthreadpool(3);

service.submit(new longtask());

service.submit(new longtask());

service.submit(new longtask());

service.submit(new longtask());

service.submit(new longtask());

listrunnables = service.shutdownnow();

system.out.println(runnables.size());

while (!service.awaittermination(1, timeunit.milliseconds))

system.out.println("執行緒池已經關閉");

這段**中,我們限制了執行緒池的長度是3,提交了5個任務,這樣將有兩個任務在工作佇列中等待,當我們執行shutdownnow方法時,executorservice被立刻關閉,所以在service.awaittermination(1, timeunit.milliseconds)方法校驗時返回的是false,因此沒有輸出:執行緒池沒有關閉。而在呼叫shutdownnow方法時,我們接受到了乙個list,這裡包含的是在工作佇列中等待執行的任務,由於執行緒池長度為3,且執行的都是長任務,所以當提交了三個任務後執行緒池已經滿了,剩下的兩次提交只能在工作佇列中等待,因此我們看到runnables的大小為2,結果如下:

2

執行緒池已經關閉

4、isterminated方法:這個方法會校驗executorservice當前的狀態是否為「terminated」即關閉狀態,當為「terminated」時返回true否則返回false。例如:

executorservice service = executors.newfixedthreadpool(3);

service.submit(new task1());

service.submit(new task1());

service.submit(new longtask());

service.shutdown();

system.out.println(system.currenttimemillis());

while (!service.isterminated())

system.out.println(system.currenttimemillis());

1303298818621

1303298828634

相差:10013毫秒,轉換一下除以1000,得到相差大約10秒

這10秒正好是長任務執行的時間,因此在 executorservice正常關閉後isterminated方法返回true。

5、isshutdown方法:這個方法在executorservice關閉後返回true,否則返回false。方法比較簡單不再舉例。

以上討論是基於threadpoolexecutor的實現,不同的實現會有所不同需注意。

執行緒池ExecutorService

執行緒池 任務提交到執行緒池,而不是直接交給某執行緒,執行緒池拿到任務後,它在內部找空閒的執行緒進行執行 封裝 任務是提交給執行緒池,乙個執行緒只能執行乙個任務,但可以同時向乙個執行緒池提交多個任務。建立固定大小的執行緒池 建立快取執行緒池 如何實現執行緒死掉後重新啟動?答案 建立單一執行緒池exe...

執行緒十四 ExecutorService

executorservice不僅能呼叫runnable的任務,它還提供了呼叫callable任務的方法。callable任務中的call方法能夠返回任務執行的結果,同時還可以丟擲受檢的異常,call方法宣告了乙個throws exception子句。為了描述executorservice的應用,我...

ExecutorService執行緒池

executorservice 建立多執行緒的步驟 1。定義執行緒類 class handler implements runnable 2。建立executorservice執行緒池 3。呼叫執行緒池操作 幾種不同的executorservice執行緒池物件 1.newcachedthreadpo...