初始化線程池后,把任務丟進去,等待調(diào)度就可以了,使用起來比較方便。JAVA中Thread是線程類,不建議直接使用Thread執(zhí)行任務,在并發(fā)數(shù)量比較多的情況下,每個線程都是執(zhí)行一個很短的時間就任務結(jié)束了,這樣頻繁創(chuàng)建線程會大大降低系統(tǒng)的效率,因為頻繁的創(chuàng)建和銷毀線程需要時間。而線程池可以復用,就是執(zhí)行完一個任務,并不銷毀,而是可以繼續(xù)執(zhí)行其它任務。

Thread的弊端 每次new Thread() 創(chuàng)建對象,性能差。 線程缺乏統(tǒng)一管理,可能無限制創(chuàng)建線程,相互競爭,有可能占用過多系統(tǒng)資源導致死機或OOM。 不能多執(zhí)行,定期執(zhí)行,線程中斷 線程池的優(yōu)點 重用存在的線程,減少對象創(chuàng)建,消亡的開銷,性能佳,降低資源消耗。 可以控制最大并發(fā)線程數(shù),提高系統(tǒng)資源利用率,同時避免過多資源競爭,避免阻塞,提高響應速度。 提供定時執(zhí)行,定期執(zhí)行,單線程,并發(fā)數(shù)控制等功能,以提高線程的可管理性。

阿里發(fā)布的 Java 開發(fā)手冊中強制線程池不允許使用 Executors 去創(chuàng)建，而是通過 ThreadPoolExecutor 的方式，這樣的處理方式讓寫的同學更加明確線程池的運行規(guī)則，規(guī)避資源耗盡的風險。Executors利用工廠模式向我們提供了4種線程池實現(xiàn)方式，但是并不推薦使用，原因是使用Executors創(chuàng)建線程池不會傳入相關(guān)參數(shù)而使用默認值所以我們常常忽略了那些重要的參數(shù)（線程池大小、緩沖隊列的類型等），而且默認使用的參數(shù)會導致資源浪費，不可取。

ThreadPoolExecutor介紹構(gòu)造函數(shù)和參數(shù)

java.uitl.concurrent.ThreadPoolExecutor類是線程池中最核心的一個類。

public class ThreadPoolExecutor extends AbstractExecutorService { /** 構(gòu)造函數(shù) 1 */ public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue) {} /** 構(gòu)造函數(shù) 2 */ public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory) {} /** 構(gòu)造函數(shù) 3 */ public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler) {} /** 構(gòu)造函數(shù) 4 */ public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {}}

ThreadPoolExecutor類中提供了四個構(gòu)造方法，在構(gòu)造函數(shù)4中，參數(shù)最多，通過觀察其他3個構(gòu)造函數(shù)，發(fā)現(xiàn)前面三個構(gòu)造器都是調(diào)用的第四個構(gòu)造器進行的初始化工作。

構(gòu)造器中各個參數(shù)的含義

corePoolSize 核心線程池的大小,在創(chuàng)建了線程池后,默認情況下,線程池中沒有任何的線程池,而是等任務過來了再去創(chuàng)建線程執(zhí)行任務。除非調(diào)用了預創(chuàng)建線程的方法,即在沒有任務到來之前就創(chuàng)建corePoolSize個線程或者一個線程。當線程池中的線程數(shù)量到達corePoolSize后,就會把到達的任務放到緩存隊列里面。

prestartCoreThread() : 預創(chuàng)建一個核心線程，使其閑置等待工作。 prestartAllCoreThreads() : 啟動所有核心線程，導致它們空閑地等待工作。

maxnumPoolSize 線程池中最大的線程數(shù),是一個非常重要的參數(shù),它表示在線程池中最多能創(chuàng)建多少線程。keepAliveTime 表示線程在沒有任務執(zhí)行時最多保持多久時間會終止。默認情況下,只有當線程池中的線程數(shù)大于corePoolSize時,keepAliveTime才會起作用,即當線程池中的線程數(shù)大于corePoolSize,如果一個線程的空閑時間達到keepAliveTime,則會終止直到線程池中的線程數(shù)量不大于corePoolSize。但是如果調(diào)用了allowCoreThreadTimeOut(boolean)方法,在線程池中線程數(shù)不大于corePoolSize時,keepAliveTime參數(shù)也會啟作用,直到線程池中的線程數(shù)為0。

unit 參數(shù)keepAliveTime的時間單位,有7種取值,在TimeUnit類中有7種靜態(tài)屬性。

TimeUnit.DAYS : 以 天 為單位 ； TimeUnit.HOURS : 以 小時 為單位 ； TimeUnit.MINUTES : 以 分鐘 為單位 ； TimeUnit.SECONDS : 以 秒 為單位 ； TimeUnit.MILLISECONDS : 以 毫秒 為單位 ； TimeUnit.MICROSECONDS : 以 微秒 為單位 ； TimeUnit.NANOSECONDS : 以 納秒 為單位 ；

workQueue一個阻塞隊列,用來存儲等待執(zhí)行的任務,這個參數(shù)的選擇也很重要,會對線程池的運行過程產(chǎn)生重大影響,一般有以下幾種選擇。

ArrayBlockingQueue:基于數(shù)組的先進先出隊列,創(chuàng)建時必須指定大小。 LinkedBlockingQueue:基于鏈表的先進先出隊列,若果創(chuàng)建時沒有指定此隊列的大小,則默認為Integer.MAX_VALUE。 SynchronousQueue:這個隊列比較特殊,它不會保存提交的任務,而是直接新建一個線程來執(zhí)行新的任務。

threadFactory線程工廠,主要用來創(chuàng)建線程。線程池最重要的一項工作,就是在滿足某些條件情況下創(chuàng)建線程。在ThreadPoolExecutor線程池中,創(chuàng)建線程的操作時交給ThreadFactoty來完成。使用線程池,就必須要指定threadFactory。如果我們的構(gòu)造器中沒有指定使用ThreadFactory,這個時候ThreadPoolExecutor就會使用默認的ThreadFactory:DefaultThreadFactoryhandler 在ThreadPoolExecutor線程池中還有一個重要的接口：RejectedExecutionHandler。當提交給線程池的某一個新任務無法直接被線程池中“核心線程”直接處理，又無法加入等待隊列，也無法創(chuàng)建新的線程執(zhí)行；又或者線程池已經(jīng)調(diào)用shutdown()方法停止了工作；又或者線程池不是處于正常的工作狀態(tài)；這時候ThreadPoolExecutor線程池會拒絕處理這個任務，觸發(fā)創(chuàng)建ThreadPoolExecutor線程池時定義的RejectedExecutionHandler接口的實現(xiàn)，表示當拒絕處理任務時的策略，有以下四種取值，四種值都為其靜態(tài)內(nèi)部類：

ThreadPoolExecutor.AbortPolicy：丟棄任務并拋出RejectedExecutionException異常 ThreadPoolExecutor.DiscardPolicy：也是丟棄任務，但是不拋出異常。 ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列最前面的任務，然后重新嘗試執(zhí)行新提交的任務。 ThreadPoolExecutor執(zhí)行execute方法分下面4種情況 如果當前運行的線程少于corePoolSize,則創(chuàng)建新的線程來執(zhí)行任務(執(zhí)行這一步驟需要獲取全局鎖) 如果運行的線程等于或者多于corePoolSize,則將任務加入到BlockingQueue 如果無法將任務加入BlockingQueue(隊列已滿),則創(chuàng)建新的線程來處理任務(執(zhí)行這一步驟需要獲取全局鎖) 如果創(chuàng)建新線程將當前運行的線程超出maxnumPoolSize,任務被拒絕,并調(diào)用RejectedExecutionHandler.rejectedExecution()方法。

以上就是Java并發(fā)線程之線程池的知識總結(jié)的詳細內(nèi)容，更多關(guān)于Java 線程池的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章！