一垢乙、線程池簡(jiǎn)介
線程的使用在Java中占有重要的地位,尤其是在執(zhí)行耗時(shí)操作(Java網(wǎng)絡(luò)編程)和異步訪問(SWT中更新界面元素)時(shí)顯得格外重要。線程雖然方便置逻,但當(dāng)需要同時(shí)執(zhí)行大量的線程操作和特定的異步訪問時(shí),通過為每一個(gè)新任務(wù)單獨(dú)新開線程就會(huì)造成大量的資源浪費(fèi)输枯,而且對(duì)同一類任務(wù)的多線程不能做到統(tǒng)一的管理议泵,所以就有了多線程的技術(shù)。
多線程技術(shù)主要解決處理器單元內(nèi)多個(gè)線程執(zhí)行的問題桃熄,它可以顯著減少處理器單元的閑置時(shí)間先口,增加處理器單元的吞吐能力。
二瞳收、Java線程池
線程池的作用:
1碉京、限制系統(tǒng)中執(zhí)行線程的數(shù)量
線程池能夠基于當(dāng)前系統(tǒng)運(yùn)行環(huán)境,通過自動(dòng)或者手動(dòng)的方式調(diào)整系統(tǒng)中運(yùn)行線程的數(shù)量螟深,從而達(dá)到節(jié)約系統(tǒng)資源的目的谐宙。設(shè)置線程池的數(shù)量可以防止程序無(wú)限制的開啟線程而造成的資源浪費(fèi),任務(wù)少的時(shí)候放入線程池中執(zhí)行界弧,任務(wù)超過線程池?cái)?shù)量限制時(shí)卧惜,排隊(duì)等待。一個(gè)任務(wù)執(zhí)行完畢后會(huì)從排隊(duì)任務(wù)重取出任務(wù)放入線程池中執(zhí)行夹纫,也就是說(shuō)當(dāng)一個(gè)新任務(wù)到來(lái)時(shí)咽瓷,如果線程池未滿則執(zhí)行新任務(wù),如果線程池已滿就需進(jìn)入等待隊(duì)列直到有空閑的線程池資源舰讹。
2茅姜、對(duì)線程的統(tǒng)一管理
開發(fā)過程中會(huì)對(duì)多個(gè)相同或者相似的任務(wù)統(tǒng)一處理的情況,線程池可以對(duì)線程統(tǒng)一管理月匣,比如:?jiǎn)拘丫€程池中所有的線程钻洒,銷毀所有的線程。
Java內(nèi)置的線程池:
Java線程池的頂級(jí)接口為Executor锄开,但一般使用較多的接口為ExecutorService素标,ExecutorService類中含有更多的對(duì)線程池的操作。
方法 | 描述 |
---|---|
isShutDown() | 如果此執(zhí)行程序已關(guān)閉萍悴,則返回 true头遭。 |
isTerminated() | 如果關(guān)閉后所有任務(wù)都已完成,則返回 true癣诱。 |
shutdown() | 啟動(dòng)一次順序關(guān)閉计维,執(zhí)行以前提交的任務(wù),但不接受新任務(wù)撕予。 |
shutdownNow() | 試圖停止所有正在執(zhí)行的活動(dòng)任務(wù)鲫惶,暫停處理正在等待的任務(wù),并返回等待執(zhí)行的任務(wù)列表实抡。 |
submit(task) | 提交一個(gè) Runnable 任務(wù)用于執(zhí)行欠母,并返回一個(gè)表示該任務(wù)的 Future欢策。 |
ExecutorService類中常用的方法:
方法 | 描述 |
---|---|
isShutDown() | 如果此執(zhí)行程序已關(guān)閉,則返回 true赏淌。 |
isTerminated() | 如果關(guān)閉后所有任務(wù)都已完成猬腰,則返回 true。 |
shutdown() | 啟動(dòng)一次順序關(guān)閉猜敢,執(zhí)行以前提交的任務(wù)姑荷,但不接受新任務(wù)。 |
shutdownNow() | 試圖停止所有正在執(zhí)行的活動(dòng)任務(wù)缩擂,暫停處理正在等待的任務(wù)鼠冕,并返回等待執(zhí)行的任務(wù)列表。 |
submit(task) | 提交一個(gè) Runnable 任務(wù)用于執(zhí)行胯盯,并返回一個(gè)表示該任務(wù)的 Future懈费。 |
為方便創(chuàng)建線程池Executors類中提供一些靜態(tài)方法,用于快速創(chuàng)建線程池博脑。
-
newCachedThreadPool
創(chuàng)建一個(gè)可緩存線程池憎乙,如果線程池大小超過處理需要,可靈活回收空閑線程叉趣,若無(wú)可回收線程泞边,則創(chuàng)建線程。此線程池不會(huì)對(duì)線程池大小限制(但可以指定初始線程池的大辛粕肌)阵谚,線程池大小完全依賴于JVM空間的限制。 - **newFixedThreadPool **
創(chuàng)建一個(gè)定長(zhǎng)線程池烟具,可控制線程最大并發(fā)數(shù)梢什,線程池一旦達(dá)到最大限制,超出的線程會(huì)在隊(duì)列中等待朝聋。 - **newScheduledThreadPool **
創(chuàng)建一個(gè)定長(zhǎng)線程池嗡午,它可安排在給定延遲后運(yùn)行命令或者定期地執(zhí)行。 - **newSingleThreadExecutor **
創(chuàng)建一個(gè)單線程化的線程池冀痕,它只會(huì)用唯一的工作線程來(lái)執(zhí)行任務(wù)荔睹,保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行。
newCachedThreadPool測(cè)試代碼:
public class NewCachedThreadPoolTest {
public static void main(String[] args) {
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
final int index = i;
try {
Thread.sleep(index * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
cachedThreadPool.execute(new Runnable() {
public void run() {
System.out.println(index);
}
});
}
}
}
當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成金度,會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程应媚,而不用每次新建線程。
newFixedThreadPool 測(cè)試代碼:
public class FixedThreadPoolTest {
public static void main(String[] args) {
//創(chuàng)建一個(gè)可重用固定線程數(shù)的線程池
ExecutorService pool = Executors.newFixedThreadPool(2);
//創(chuàng)建實(shí)現(xiàn)了Runnable接口對(duì)象猜极,Thread對(duì)象當(dāng)然也實(shí)現(xiàn)了Runnable接口
Thread t1 = new MyThread();
Thread t2 = new MyThread();
Thread t3 = new MyThread();
Thread t4 = new MyThread();
Thread t5 = new MyThread();
//將線程放入池中進(jìn)行執(zhí)行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//關(guān)閉線程池
pool.shutdown();
}
}
輸出結(jié)果:
pool-1-thread-1正在執(zhí)行。消玄。跟伏。
pool-1-thread-2正在執(zhí)行丢胚。。受扳。
pool-1-thread-1正在執(zhí)行携龟。。勘高。
pool-1-thread-2正在執(zhí)行峡蟋。。华望。
pool-1-thread-1正在執(zhí)行蕊蝗。。赖舟。
newScheduledThreadPool 測(cè)試代碼:
public class ScheduledThreadPoolExecutorTest {
public static void main(String[] args) {
ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1);
exec.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
System.out.println("================");
}
}, 1000, 5000, TimeUnit.MILLISECONDS);
exec.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
System.out.println(System.nanoTime());
}
}, 1000, 2000, TimeUnit.MILLISECONDS);
}
}
輸出結(jié)果:
================
41070644908191
41072644693809
41074645495462
================
41076644808412
41078644896218
================
41080645104328
41082645027356
41084645111170
================
41086645135117
41088645164196
newScheduledThreadPool 測(cè)試代碼:
public class SingleThreadExecutorTest
{
public static void main(String[] args) {
ExecutorService pool = Executors.newSingleThreadExecutor();
Thread t1 = new MyThread();
Thread t2 = new MyThread();
Thread t3 = new MyThread();
Thread t4 = new MyThread();
Thread t5 = new MyThread();
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
// 關(guān)閉線程池
pool.shutdown();
}
}
輸出結(jié)果:
pool-1-thread-1正在執(zhí)行蓬戚。。宾抓。
pool-1-thread-1正在執(zhí)行子漩。。石洗。
pool-1-thread-1正在執(zhí)行幢泼。。讲衫。
pool-1-thread-1正在執(zhí)行旭绒。。焦人。
pool-1-thread-1正在執(zhí)行挥吵。。花椭。
每種線程池都會(huì)有特定的使用場(chǎng)景忽匈,上述四種線程池能滿足大部分的需求。