在我們工作當(dāng)中經(jīng)常會遇到一些很耗時的操作器腋,處理這些耗時的操作我們會開啟多線程服務(wù)。但是線程太多依舊會影響性能,因此很多時候我們會采統(tǒng)一管理線程纫塌。這就是線程池诊县。
線程池總共有三種,下面一一介紹措左。
1.newFixedThreadPool
概念:
如果有線程加入后依痊,首先先回判斷線程池里有沒有可用的線程,如果正在運行的線程已經(jīng)達(dá)到了線程池的最大值怎披,那么這個線程就將被阻塞胸嘁。直到有可用的線程被釋放出來。
使用:
step1:先創(chuàng)建一個線程池的實例并且分配你想要的線程的數(shù)量凉逛,如:
ExecutorService pool = newExecutors.newFixedThreadPool(count)
step2: 創(chuàng)建自己的線程缴渊,一般是實現(xiàn)Runnable,如:
先創(chuàng)建一個Thread實現(xiàn)Runable鱼炒,
calss MyThread implements Runnable {
...
public void run(){}
}
step3: 執(zhí)行
MyThread runabble = new MyThread();
pool.execute(runabble);
2.newCacheThreadPool
概念:
創(chuàng)建一個可以緩存的線程池,如果線程池的長度大于處理需要的蝌借,就可以回收空閑線程昔瞧,不需要重現(xiàn)創(chuàng)建。反之則需要重新創(chuàng)建菩佑。
使用:
和上面使用一樣自晰,有一點就是不需要給線程池分配大小。如:
ExecutorService pool =Executors.newCacheThreadPool();
好處:
復(fù)用率還是挺高的稍坯,線程池數(shù)量可以無限大酬荞,當(dāng)?shù)谝粋€線程執(zhí)行結(jié)束后,第二個線程可以復(fù)用第一個線程而不需要重新建立新的線程瞧哟。
3.newSingleThreadExecutor
概念:
顧名思義混巧,是創(chuàng)建一個單線程池,所有的線程都要按照一定的順序勤揩,優(yōu)先級的執(zhí)行咧党。并且使用的是唯一的工作線程來執(zhí)行。
使用:
和以上兩個的使用區(qū)別不大陨亡,可以創(chuàng)建多個線程傍衡,然后發(fā)現(xiàn)都是順序執(zhí)行下來的。
4. 共同原理
都是采用線程池的方法來管理線程负蠕,使用的方法基本上都是一樣的蛙埂。初衷都是一樣,都是為了提高性能遮糖。
5.ExecutorService相關(guān)
Executors
Executors是一個工廠類專門負(fù)責(zé)創(chuàng)建各種線程池绣的,就如上面提到的三種線程池。都是用這個創(chuàng)建的。并且可以返回以下類:
ExecutorService
上面都是用到的通過實例三種不同的線程池返回的都是此類型被辑。方法分別是:
shutdown停止線程燎悍,但是允許前一個線程執(zhí)行完畢
shutdownNow停止線程,包括正在運行的盼理。
submit繼承execute的base方法谈山,可用來取消或等待
ScheduleExecutorService
定時任務(wù),可以定時的執(zhí)行線程池的任務(wù).主要的方法分別是:
schedule(task, intdelyTime)任務(wù)在指定時間后執(zhí)行宏怔。
scheduleAtFixedRate(task,intstart, int end, TimeUnit.SECONDS);在時間段內(nèi)重復(fù)執(zhí)行
scheduleWithFixedDely()上次任務(wù)完成結(jié)束后奏路,在delay的時間后執(zhí)行
Callable
有返回值并且可能拋出異常,類似于Runnable也可以被其他thread執(zhí)行臊诊,但是Runnable沒有返回值也沒異常檢測鸽粉。
ThreadFactory
根據(jù)需要可以創(chuàng)建一個Thread。也可以移除一個線程用法如下:
classSimpleThreadFactoryimplementsThreadFactory{
publicThreadnewThread(Runnabler){
returnnewThread(r);
}}
6. 工作實際遇到的實例
在我的實際工作當(dāng)中主要用的是newFixedThreadPool.用來處理一些耗時的操作抓艳,頻繁請求網(wǎng)絡(luò)的操作触机。如一些圖片的加載。
publicBdImageLoader(Context context, booleanaDirectly,String aPath, longaLimitSize) {
mContext= context;
mMemoryCache=newBdMemoryCache(aLimitSize);
mFileCache=newBdFileCache(context,aPath);
mImageViews= Collections.synchronizedMap(newWeakHashMap, String>());
mExecutorService= Executors.newFixedThreadPool(MAX_THREAD_COUNT);
mDirectly= aDirectly;
}
private voidqueryIcon(String url,ImageView imageView) {
IconToLoad p =newIconToLoad(url,imageView);
mExecutorService.submit(newPhotosLoader(p));
}
classPhotosLoaderimplementsRunnable {
privateIconToLoadmIconToLoad;
7. 鏈接
http://android.toolib.net/reference/java/util/concurrent/ExecutorService.html