? ? 在日常應用開發(fā)中儿子,經(jīng)常會有一些耗時操作瓦哎,比如數(shù)據(jù)庫操作、網(wǎng)絡請求等柔逼,碰見這種情況蒋譬,我們一般會怎么做呢?當然第一反應就是放到子線程去異步處理愉适,張手就一個new Thread().start就來了犯助,這樣的操作在線程少的情況下是沒問題的,也能實現(xiàn)功能维咸,但這樣久之會造成嚴重的性能損耗剂买,有的同學就會問為什么?我告訴你為什么癌蓖,原因如下:
? ? 一瞬哼、JAVA線程機制是搶占性質的,new Thread出來的匿名線程非常難以管理租副,都是些野猴子坐慰,缺乏管束,雖然JAVA提供了線程優(yōu)先級的方法用僧,但通常效果并不理想结胀,有時候就很混亂赞咙,而且JAVA線程機制會給每個線程提供時間片,“野”線程多了糟港,自然會影響耗能攀操。
? ? 二、JAVA中你每次new Thread的時候着逐,在難以管理的情形下崔赌,銷毀線程的性能是很差的,而線程池復用線程的特性極大的提高了效率和性能耸别。
? ? 三健芭、new Thread功能比較單一,沒有定時執(zhí)行秀姐、線程中斷等功能慈迈。
? ? 好了,上面三點就是原因了省有,所以線程池還是很有必要的痒留,接下來我們來介紹一下吧。
在JAVA JDK1.5上提供了Executor框架蠢沿,這框架就是用來把任務的提交和執(zhí)行解耦伸头,其核心成員就是ThreadPoolExecutor,這也是線程池的核心實現(xiàn)類。其構造方法如下:
? ? ?corePoolSize ??
? ? ?表示核心線程數(shù)舷蟀,默認情況下恤磷,線程池是空的,只有提交任務的時候才會創(chuàng)建線程野宜,核心線程會在線程池中一直存活扫步,只不過是處于閑置狀態(tài),除非你把ThreadPoolExecutor的allowCoreThreadTimeOut屬性設為true,就會有超時策略匈子,即核心線程的生命周期會受keepAliveTime的限制河胎,時間一到,就會終止虎敦。還有游岳,如果你調用線程池的prestartAllCoreThread方法,線程池就會提前重新創(chuàng)建并啟動所有的核心線程去等待任務其徙。
? ? ?maximumPoolSize
? ? ?表示允許線程池創(chuàng)建的最大線程數(shù)吭历。當活動的線程小于maximumPoolSize設定的線程數(shù),就創(chuàng)建線程執(zhí)行任務擂橘,否則新任務被阻塞,排隊等待摩骨。
? ? ?keepAliveTime
? ? ?表示非核心線程閑置的超時時長通贞,超過時間則會被回收朗若。如果遇見任務短而且很多的情況,你可以通過調大這個屬性值來提高線程的利用率昌罩。
? ? ?TimeUnit
? ? ?表示keepAliveTime的時間單位哭懈,這是一個枚舉,從天(DAYS)到納秒(NANOSECONDS)茎用。
? ? ?workQueue
? ? ?表示一個阻塞的任務隊列遣总,線程池的execute方法提交的Runnable對象會存儲在這個參數(shù)中,阻塞隊列的概念就不說了轨功,大家自行百度旭斥。
? ? ?ThreadFactory
? ? ?表示線程工廠,線程池在創(chuàng)建線程的就是用的它古涧,用Thread newThread(Runnable r)來執(zhí)行創(chuàng)建線程操作垂券。
? ? ?RejectedExecutionHandler
? ? 表示線程池的飽和策略,用于線程池和任務隊列滿了的情況下使用的策略羡滑,默認是abordPolicy菇爪,表示無法處理新任務,這個時候ThreadPoolExecutor會調用handler的rejectedExecution方法通知調用者柒昏,并會直接拋出一個RejectedExecutionException凳宙,此外還有三種策略,分別是CallerRunsPolicy职祷、DiscardPolicy氏涩、DiscardOldestPolicy,這些東西并不常用堪旧,但我想這個還是有必要普及一下削葱,
(1)CallerRunsPolicy:用調用者所在的線程處理任務,也就是說淳梦,放下手中的活幫我處理掉的意思析砸。
(2)DiscardPolicy:直接拋棄新任務
(3)DiscardOldestPolicy:丟棄隊列中最近的任務,并執(zhí)行新任務
好了爆袍,關于ThreadPoolExecutor的介紹就到這里首繁,下面我們來看看它的幾位小弟吧。
FixedThreadPool
這類線程池的特點就是里面全是核心線程陨囊,沒有非核心線程弦疮,也沒有超時機制,任務大小也是沒有限制的蜘醋,數(shù)量固定胁塞,即使是空閑狀態(tài),線程不會被回收,除非線程池被關閉啸罢,從構造方法也可以看出來编检,只有兩個參數(shù),一個是指定的核心線程數(shù)扰才,一個是線程工廠允懂,keepAliveTime無效。任務隊列采用了無界的阻塞隊列LinkedBlockingQueue衩匣,執(zhí)行execute方法的時候蕾总,運行的線程沒有達到corePoolSize就創(chuàng)建核心線程執(zhí)行任務,否則就阻塞在任務隊列中琅捏,有空閑線程的時候去取任務執(zhí)行生百。由于該線程池線程數(shù)固定,且不被回收午绳,線程與線程池的生命周期同步置侍,所以適用于任務量比較固定但耗時長的任務。
CachedThreadPool
這類線程池的特點就是里面沒有核心線程拦焚,全是非核心線程蜡坊,其maximumPoolSize設置為Integer.MAX_VALUE,線程可以無限創(chuàng)建赎败,當線程池中的線程都處于活動狀態(tài)的時候秕衙,線程池會創(chuàng)建新的線程來處理新任務,否則會用空閑的線程來處理新任務僵刮,這類線程池的空閑線程都是有超時機制的据忘,keepAliveTime在這里是有效的,時長為60秒搞糕,超過60秒的空閑線程就會被回收勇吊,當線程池都處于閑置狀態(tài)時,線程池中的線程都會因為超時而被回收窍仰,所以幾乎不會占用什么系統(tǒng)資源汉规。任務隊列采用的是SynchronousQueue,這個隊列是無法插入任務的驹吮,一有任務立即執(zhí)行针史,所以CachedThreadPool比較適合任務量大但耗時少的任務。
ScheduledThreadPool
這類線程池核心線程數(shù)量是固定的碟狞,好像和FixThreadPool有點像啄枕,但是它的非核心線程是沒有限制的,并且非核心線程一閑置就會被回收族沃,keepAliveTime同樣無效频祝,因為核心線程是不會回收的泌参,當運行的線程數(shù)沒有達到corePoolSize的時候,就新建線程去DelayedWorkQueue中取ScheduledFutureTask然后才去執(zhí)行任務常空,否則就把任務添加到DelayedWorkQueue及舍,DelayedWorkQueue會將任務排序,按新建一個非核心線程順序執(zhí)行窟绷,執(zhí)行完線程就回收,然后循環(huán)咐柜。任務隊列采用的DelayedWorkQueue是個無界的隊列兼蜈,延時執(zhí)行隊列任務。綜合來說拙友,這類線程池適用于執(zhí)行定時任務和具體固定周期的重復任務为狸。
SingleThreadPool
這類線程池顧名思義就是一個只有一個核心線程的線程池,從構造方法來看遗契,它可以單獨執(zhí)行辐棒,也可以與周期線程池結合用。其任務隊列是LinkedBlockingQueue牍蜂,這是個無界的阻塞隊列漾根,因為線程池里只有一個線程,就確保所有的任務都在同一個線程中順序執(zhí)行鲫竞,這樣就不需要處理線程同步的問題辐怕。這類線程池適用于多個任務順序執(zhí)行的場景。
It's over!相信到這里从绘,四大線程池的特點已經(jīng)很清晰了寄疏,歡迎大家吐嘈!