摘要:線(xiàn)程池根據(jù)當(dāng)前在系統(tǒng)中運(yùn)行的進(jìn)程來(lái)優(yōu)化線(xiàn)程片。線(xiàn)程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線(xiàn)程數(shù)量限制問(wèn)題。線(xiàn)程池中允許的線(xiàn)程最大數(shù)量,當(dāng)活動(dòng)線(xiàn)程達(dá)到這個(gè)數(shù)值后,后續(xù)的新任務(wù)會(huì)被阻塞。
每個(gè) Android 應(yīng)用進(jìn)程在創(chuàng)建時(shí),會(huì)同時(shí)創(chuàng)建一個(gè)線(xiàn)程,我們稱(chēng)之為主線(xiàn)程,負(fù)責(zé)更新 UI 界面以及和處理用戶(hù)之間的交互,因此,在 Android 中,我們又稱(chēng)之為 UI 線(xiàn)程。一個(gè)進(jìn)程中 UI 線(xiàn)程只有一個(gè),為了不造成界面卡頓、提高用戶(hù)體驗(yàn),我們勢(shì)必要將一些耗時(shí)操作交由子線(xiàn)程來(lái)執(zhí)行。
使用子線(xiàn)程的方式主要分兩種:
直接使用 Thread 和 Runnable 等創(chuàng)建子并使用線(xiàn)程
使用線(xiàn)程池創(chuàng)建并使用子線(xiàn)程
線(xiàn)程池是什么
線(xiàn)程池是指在初始化一個(gè)多線(xiàn)程應(yīng)用程序過(guò)程中創(chuàng)建一個(gè)線(xiàn)程集合,然后在需要執(zhí)行新的任務(wù)時(shí)重用這些線(xiàn)程而不是新創(chuàng)建一個(gè)線(xiàn)程。線(xiàn)程池中線(xiàn)程的數(shù)量通常完全取決于可用內(nèi)存數(shù)量和應(yīng)用程序的需求;每個(gè)線(xiàn)程都有被分配一個(gè)任務(wù),一旦任務(wù)完成了,線(xiàn)程回到池子中并等待下一次分配任務(wù)。
一般情況下,推薦使用線(xiàn)程池來(lái)創(chuàng)建和使用子線(xiàn)程,不建議使用第一種方式。
為何要用線(xiàn)程池上面說(shuō)了,在 Android 開(kāi)發(fā)過(guò)程中,建議使用線(xiàn)程池來(lái)創(chuàng)建和使用子線(xiàn)程,那么使用線(xiàn)程池的好處有哪些呢?
線(xiàn)程池改進(jìn)了一個(gè)應(yīng)用程序的響應(yīng)時(shí)間。由于線(xiàn)程池中的線(xiàn)程已經(jīng)準(zhǔn)備好且等待被分配任務(wù),應(yīng)用程序可以直接拿來(lái)使用而不用新建一個(gè)線(xiàn)程。
線(xiàn)程池節(jié)省了 CLR 為每個(gè)短生存周期任務(wù)創(chuàng)建一個(gè)完整的線(xiàn)程開(kāi)銷(xiāo)并可以在任務(wù)完成后回收資源。
線(xiàn)程池根據(jù)當(dāng)前在系統(tǒng)中運(yùn)行的進(jìn)程來(lái)優(yōu)化線(xiàn)程片。
線(xiàn)程池允許我們開(kāi)啟多個(gè)任務(wù)而不用為每個(gè)線(xiàn)程設(shè)置屬性。
線(xiàn)程池允許我們?yōu)檎趫?zhí)行的任務(wù)的程序參數(shù)傳遞一個(gè)包含狀態(tài)信息的對(duì)象引用。
線(xiàn)程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線(xiàn)程數(shù)量限制問(wèn)題。
系統(tǒng)分配給每個(gè)應(yīng)用的線(xiàn)程棧是固定的,使用線(xiàn)程池可以有效地避免線(xiàn)程棧溢出引起的應(yīng)用崩潰。
Android 中的線(xiàn)程池Android 中線(xiàn)程池的真正實(shí)現(xiàn)是 ThreadPoolExecutor,其構(gòu)造方法有 5 個(gè),通過(guò)一系列參數(shù)來(lái)配置線(xiàn)程池。下面介紹一個(gè)比較常用的構(gòu)造方法及其參數(shù)的含義。
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueueworkQueue, ThreadFactory threadFactory)
參數(shù) | 含義 |
---|---|
corePoolSize | int: 線(xiàn)程池的核心線(xiàn)程數(shù),默認(rèn)情況下,核心線(xiàn)程回一直在線(xiàn)程池中存活,即使他們處于閑置狀態(tài)。如果將 allowCoreThreadTimeOut 的屬性設(shè)置為 true,那么閑置的核心線(xiàn)程在等待新任務(wù)到來(lái)時(shí)會(huì)有超時(shí)策略,這個(gè)時(shí)間間隔由 keepAliveTime 所指定,當(dāng)?shù)却龝r(shí)間超過(guò) keepAliveTime 所指定的時(shí)長(zhǎng)后,核心線(xiàn)程就會(huì)被終止。 |
maximumPoolSize | int: 線(xiàn)程池中允許的線(xiàn)程最大數(shù)量,當(dāng)活動(dòng)線(xiàn)程達(dá)到這個(gè)數(shù)值后,后續(xù)的新任務(wù)會(huì)被阻塞。 |
keepAliveTime | long: 非核心線(xiàn)程閑置時(shí)的超時(shí)時(shí)長(zhǎng),超過(guò)這個(gè)時(shí)長(zhǎng),非核心線(xiàn)程就會(huì)被回收。當(dāng) allowCoreThreadTimeOut 屬性被設(shè)置為 true 時(shí),該參數(shù)同樣會(huì)作用于核心線(xiàn)程。 |
unit | TimeUnit: keepAliveTime 參數(shù)的時(shí)間單位 ,參數(shù)為 TimeUnit 的枚舉,常見(jiàn)的有 TimeUnit.MILLISECONDS(毫秒)、TimeUnit.SECOND(秒) 等。 |
workQueue | BlockingQueue: 線(xiàn)程池中的任務(wù)隊(duì)列,通過(guò)線(xiàn)程池的 execute 方法提交的 Runnable 對(duì)象會(huì)存儲(chǔ)在這個(gè)參數(shù)中。 |
threadFactory | ThreadFactory: 創(chuàng)建線(xiàn)程的線(xiàn)程工廠(chǎng)。ThreadFactory 是一個(gè)接口,只有一個(gè)方法:Thread newThread (Runnable r) |
Throws | |
---|---|
IllegalArgumentException | 符合以下任一條件,則拋出此異常: corePoolSize < 0 keepAliveTime < 0 maximumPoolSize <= 0 maximumPoolSize < corePoolSize |
NullPointerException | 當(dāng) workQueue 或者 threadFactory 為 null 時(shí),拋出此異常。 |
ThreadPoolExecutor 執(zhí)行任務(wù)時(shí)大致遵循如下規(guī)則:
如果線(xiàn)程池中的線(xiàn)程數(shù)量未達(dá)到核心線(xiàn)程的數(shù)量,那么會(huì)直接啟動(dòng)一個(gè)核心線(xiàn)程來(lái)執(zhí)行任務(wù)。
如果線(xiàn)程池中的線(xiàn)程數(shù)量已經(jīng)達(dá)到或超過(guò)核心線(xiàn)程的數(shù)量,那么任務(wù)會(huì)被插入到任務(wù)隊(duì)列中等待執(zhí)行。
如果步驟 2 中無(wú)法將任務(wù)插入到任務(wù)隊(duì)列,則表示任務(wù)隊(duì)列已滿(mǎn)。此時(shí),如果線(xiàn)程數(shù)量未達(dá)到 maximumPoolSize 值,則會(huì)立即啟動(dòng)一個(gè)非核心線(xiàn)程來(lái)執(zhí)行任務(wù)。
如果步驟 3 中線(xiàn)程數(shù)量大于或等于 maximumPoolSize 值,則拒絕執(zhí)行次任務(wù),此時(shí) ThreadPoolExecutor 會(huì)調(diào)用 RejectedExecutionHandler 的 rejectedExecution 來(lái)通知調(diào)用者。
RejectedExecutionHandler 是線(xiàn)程池持有的一個(gè)對(duì)象,用于不能由 ThreadPoolExecutor 執(zhí)行的任務(wù)的處理Android 中線(xiàn)程池的類(lèi)型及區(qū)別
Android 中最常見(jiàn)線(xiàn)程池有四種,分別是:FixedThreadPool、CacheThreadPool、ScheduledThreadPool 以及 SingleThreadPool,它們都直接或間接的通過(guò)配置 ThreadPoolExecutor 來(lái)實(shí)現(xiàn)自己的功能特性。
1. FixedThreadPool線(xiàn)程數(shù)量固定的線(xiàn)程池,通過(guò) Executors 的 newFixedThreadPool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法:
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()); }
public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(), threadFactory); }
除非線(xiàn)程池被關(guān)閉,否則線(xiàn)程不會(huì)被回收,即時(shí)線(xiàn)程處于空閑狀態(tài)。如果在所有線(xiàn)程都處于活動(dòng)狀態(tài)時(shí)提交額外的任務(wù),它們將在隊(duì)列中等待,直到有一個(gè)線(xiàn)程可用為止。由創(chuàng)建方法可知,F(xiàn)ixedThreadPool 只有核心線(xiàn)程并且這個(gè)核心線(xiàn)程沒(méi)有超時(shí)機(jī)制(keepAliveTime 參數(shù)為 0L),加上線(xiàn)程不會(huì)被回收,因此使用此類(lèi)線(xiàn)程池可以快速地響應(yīng)外界的請(qǐng)求。
2. CacheThreadPool線(xiàn)程數(shù)量不定的線(xiàn)程池,通過(guò) Executors 的 newCachedThreadPool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法:
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(/* corePoolSize*/ 0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue()); }
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) { return new ThreadPoolExecutor(/* corePoolSize*/ 0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue(), threadFactory); }
CacheThreadPool 有以下個(gè)特征:
沒(méi)有核心線(xiàn)程( corePoolSize 參數(shù)為 0 ),只有非核心線(xiàn)程且非核心線(xiàn)程的數(shù)量為 Integer.MAX_VALUE,這就相當(dāng)于非核心線(xiàn)程的數(shù)量可以無(wú)限大。
線(xiàn)程池的線(xiàn)程處于空閑狀態(tài)時(shí),線(xiàn)程池會(huì)重用空閑的線(xiàn)程來(lái)處理新任務(wù),否則創(chuàng)建新的線(xiàn)程來(lái)處理,新創(chuàng)建的線(xiàn)程會(huì)添加到線(xiàn)程池中。這將提高執(zhí)行許多短期異步任務(wù)的程序性能。
閑置時(shí)間超過(guò) 60 秒的空閑線(xiàn)程會(huì)被回收(keepAliveTime 參數(shù)為 60L )。因此,閑置時(shí)間足夠長(zhǎng)的 CacheThreadPool 也不會(huì)消耗任何系統(tǒng)資源。
3. ScheduledThreadPool核心線(xiàn)程數(shù)量固定,非核心線(xiàn)程數(shù)量不定的線(xiàn)程池,通過(guò) Executors 的 newscheduledthreadpool 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法:
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) { return new ScheduledThreadPoolExecutor(corePoolSize); }
public static ScheduledExecutorService newScheduledThreadPool( int corePoolSize, ThreadFactory threadFactory) { return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory); }
ScheduledThreadPool 相比較其他三種線(xiàn)程池,有特殊性,由 ScheduledThreadPoolExecutor 實(shí)現(xiàn), newscheduledthreadpool 方法也是通過(guò)創(chuàng)建 ScheduledThreadPoolExecutor 的實(shí)例來(lái)完成線(xiàn)程池的創(chuàng)建,代碼如下:
public ScheduledThreadPoolExecutor(int corePoolSize) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue()); }
public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue(), threadFactory); }
由 ScheduledThreadPoolExecutor 的構(gòu)造函數(shù)可知, ScheduledThreadPool 的核心線(xiàn)程數(shù)量是固定的,由傳入的 corePoolSize 參數(shù)決定,非核心線(xiàn)程數(shù)量可以無(wú)限大。非核心線(xiàn)程閑置回收的超時(shí)時(shí)間為 10秒( DEFAULT_KEEPALIVE_MILLIS 的值為 10L )。這類(lèi)線(xiàn)程主要用于執(zhí)行定時(shí)任務(wù)或者具有周期性的重復(fù)任務(wù)。
4. SingleThreadPool只有一個(gè)核心線(xiàn)程,通過(guò) Executors 的 newsinglethreadexecutor 方法創(chuàng)建。有兩個(gè)重載的創(chuàng)建方法:
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(/* corePoolSize*/ 1, /* maximumPoolSize*/ 1, /* keepAliveTime*/ 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue())); }
public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(/* corePoolSize*/ 1, /* maximumPoolSize*/ 1, /* keepAliveTime*/ 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(), threadFactory)); }
SingleThreadPool 由 代理類(lèi) FinalizableDelegatedExecutorService 創(chuàng)建。該線(xiàn)程池只有一個(gè)線(xiàn)程(核心線(xiàn)程),并且該線(xiàn)程池的任務(wù)隊(duì)列是無(wú)上限的,這就確保了所有的任務(wù)都在同一個(gè)線(xiàn)程中順序執(zhí)行。
注意,如果由于在執(zhí)行期間出現(xiàn)故障而導(dǎo)致該線(xiàn)程終止,那么如果需要執(zhí)行后續(xù)任務(wù),則新線(xiàn)程將取而代之。四類(lèi)線(xiàn)程池的區(qū)別
上面分別對(duì) Android 中常見(jiàn)的 4 種線(xiàn)程池進(jìn)行了簡(jiǎn)單的介紹,除了這 4 種系統(tǒng)提供的線(xiàn)程池外,我們?cè)谑褂玫倪^(guò)程中,也可以根據(jù)需要直接通過(guò) ThreadPoolExecutor 的構(gòu)造函數(shù)來(lái)靈活的配置線(xiàn)程池。那么,上述的 4 種線(xiàn)程池,其區(qū)別在哪呢?了解其區(qū)別有助于我們?nèi)ミx擇更為合適的線(xiàn)程池或者直接通過(guò) ThreadPoolExecutor 來(lái)配置更靈活的線(xiàn)程池。
FixedThreadPool 線(xiàn)程固定,且不會(huì)被回收,能夠更快的響應(yīng)外界請(qǐng)求。
CachedThreadPool 只有非核心線(xiàn)程,且線(xiàn)程數(shù)相當(dāng)于無(wú)限大,任何任務(wù)都會(huì)被立即執(zhí)行。比較適合執(zhí)行大量的耗時(shí)較少的任務(wù)。
ScheduledThreadPool 主要用于執(zhí)行定時(shí)任務(wù)或者具有周期性的重復(fù)任務(wù)。
SingleThreadPool 只有一個(gè)核心線(xiàn)程,確保所有任務(wù)都在同一線(xiàn)程中按順序完成。因此不需要處理線(xiàn)程同步的問(wèn)題。
參考《Android藝術(shù)開(kāi)發(fā)探索》,電子書(shū)下載
Android 官方文檔
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/69640.html
摘要:目錄介紹問(wèn)題匯總具體問(wèn)題好消息博客筆記大匯總年月到至今,包括基礎(chǔ)及深入知識(shí)點(diǎn),技術(shù)博客,學(xué)習(xí)筆記等等,還包括平時(shí)開(kāi)發(fā)中遇到的匯總,當(dāng)然也在工作之余收集了大量的面試題,長(zhǎng)期更新維護(hù)并且修正,持續(xù)完善開(kāi)源的文件是格式的同時(shí)也開(kāi)源了生活博客,從年 目錄介紹 00.Java問(wèn)題匯總 01.具體問(wèn)題 好消息 博客筆記大匯總【16年3月到至今】,包括Java基礎(chǔ)及深入知識(shí)點(diǎn),Android技...
摘要:線(xiàn)程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線(xiàn)程數(shù)量限制問(wèn)題。安撫多歲的發(fā)發(fā)發(fā)線(xiàn)程池的作用線(xiàn)程池作用就是限制系統(tǒng)中執(zhí)行線(xiàn)程的數(shù)量。若隊(duì)列中沒(méi)有等待進(jìn)程,線(xiàn)程池的這一資源處于等待。此線(xiàn)程池支持定時(shí)以及周期性執(zhí)行任務(wù)的需求。 前言 面試中我們經(jīng)常會(huì)遇到多線(xiàn)程和線(xiàn)程池的問(wèn)題,究竟如何回答呢?今天關(guān)于Java中的線(xiàn)程池,我們就來(lái)學(xué)習(xí)一下。 什么是線(xiàn)程池 線(xiàn)程池是指在初始化一個(gè)多線(xiàn)程應(yīng)用程序過(guò)程中創(chuàng)建...
摘要:線(xiàn)程池可以用來(lái)解決處理一個(gè)特定請(qǐng)求最大線(xiàn)程數(shù)量限制問(wèn)題。安撫多歲的發(fā)發(fā)發(fā)線(xiàn)程池的作用線(xiàn)程池作用就是限制系統(tǒng)中執(zhí)行線(xiàn)程的數(shù)量。若隊(duì)列中沒(méi)有等待進(jìn)程,線(xiàn)程池的這一資源處于等待。此線(xiàn)程池支持定時(shí)以及周期性執(zhí)行任務(wù)的需求。 前言 面試中我們經(jīng)常會(huì)遇到多線(xiàn)程和線(xiàn)程池的問(wèn)題,究竟如何回答呢?今天關(guān)于Java中的線(xiàn)程池,我們就來(lái)學(xué)習(xí)一下。 什么是線(xiàn)程池 線(xiàn)程池是指在初始化一個(gè)多線(xiàn)程應(yīng)用程序過(guò)程中創(chuàng)建...
閱讀 2470·2023-04-25 14:29
閱讀 1642·2021-11-22 09:34
閱讀 2847·2021-11-22 09:34
閱讀 3531·2021-11-11 10:59
閱讀 1997·2021-09-26 09:46
閱讀 2387·2021-09-22 16:03
閱讀 2080·2019-08-30 12:56
閱讀 597·2019-08-30 11:12