從JDK 5開始,把工作單元與執(zhí)行機(jī)制分離開來,工作單元包括Runnable和Callable,而執(zhí)行機(jī)制由Executor框架提供。
WorkerThread
SimpleThreadPool
程序中我們創(chuàng)建了固定大小為五個(gè)工作線程的線程池。然后分配給線程池十個(gè)工作,因?yàn)榫€程池大小為五,它將啟動五個(gè)工作線程先處理五個(gè)工作,其他的工作則處于等待狀態(tài),一旦有工作完成,空閑下來工作線程就會撿取等待隊(duì)列里的其他工作進(jìn)行執(zhí)行。
這里是以上程序的輸出。
輸出表明線程池中至始至終只有五個(gè)名為 "pool-1-thread-1" 到 "pool-1-thread-5" 的五個(gè)線程,這五個(gè)線程不隨著工作的完成而消亡,會一直存在,并負(fù)責(zé)執(zhí)行分配給線程池的任務(wù),直到線程池消亡。
Executors 類提供了使用了 ThreadPoolExecutor 的簡單的 ExecutorService 實(shí)現(xiàn),但是 ThreadPoolExecutor 提供的功能遠(yuǎn)不止于此。我們可以在創(chuàng)建 ThreadPoolExecutor 實(shí)例時(shí)指定活動線程的數(shù)量,我們也可以限制線程池的大小并且創(chuàng)建我們自己的 RejectedExecutionHandler 實(shí)現(xiàn)來處理不能適應(yīng)工作隊(duì)列的工作。
這里是我們自定義的 RejectedExecutionHandler 接口的實(shí)現(xiàn)。
RejectedExecutionHandlerImpl.java
ThreadPoolExecutor 提供了一些方法,我們可以使用這些方法來查詢 executor 的當(dāng)前狀態(tài),線程池大小,活動線程數(shù)量以及任務(wù)數(shù)量。因此我是用來一個(gè)監(jiān)控線程在特定的時(shí)間間隔內(nèi)打印 executor 信息。
MyMonitorThread.java
注意在初始化 ThreadPoolExecutor 時(shí),我們保持初始池大小為 2,最大池大小為 4 而工作隊(duì)列大小為 2。因此如果已經(jīng)有四個(gè)正在執(zhí)行的任務(wù)而此時(shí)分配來更多任務(wù)的話,工作隊(duì)列將僅僅保留他們(新任務(wù))中的兩個(gè),其他的將會被 RejectedExecutionHandlerImpl 處理。
上面程序的輸出可以證實(shí)以上觀點(diǎn)。
注意 executor 的活動任務(wù)、完成任務(wù)以及所有完成任務(wù),這些數(shù)量上的變化。我們可以調(diào)用 shutdown() 方法來結(jié)束所有提交的任務(wù)并終止線程池。