從 Java 5 開始,Java 提供了自己的線程池。線程池就是一個線程的容器,每次只執(zhí)行額定數(shù)量的線程。 java.util.concurrent.ThreadPoolExecutor 就是這樣的線程池。它很靈活,但使用起來也比較復(fù)雜,本文就對其做一個介紹。
首先是構(gòu)造函數(shù)。以最簡單的構(gòu)造函數(shù)為例:
view plaincopy to clipboardprint?
public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue)
public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue)
看起來挺復(fù)雜的。這里介紹一下。
corePoolSize 指的是保留的線程池大小。
maximumPoolSize 指的是線程池的最大大小。
keepAliveTime 指的是空閑線程結(jié)束的超時時間。
unit 是一個枚舉,表示 keepAliveTime 的單位。
workQueue 表示存放任務(wù)的隊列。
我們可以從線程池的工作過程中了解這些參數(shù)的意義。線程池的工作過程如下:
1、線程池剛創(chuàng)建時,里面沒有一個線程。任務(wù)隊列是作為參數(shù)傳進(jìn)來的。不過,就算隊列里面有任務(wù),線程池也不會馬上執(zhí)行它們。
2、當(dāng)調(diào)用 execute() 方法添加一個任務(wù)時,線程池會做如下判斷:
a. 如果正在運行的線程數(shù)量小于 corePoolSize,那么馬上創(chuàng)建線程運行這個任務(wù);
b. 如果正在運行的線程數(shù)量大于或等于 corePoolSize,那么將這個任務(wù)放入隊列。
c. 如果這時候隊列滿了,而且正在運行的線程數(shù)量小于 maximumPoolSize,那么還是要創(chuàng)建線程運行這個任務(wù);
d. 如果隊列滿了,而且正在運行的線程數(shù)量大于或等于 maximumPoolSize,那么線程池會拋出異常,告訴調(diào)用者“我不能再接受任務(wù)了”。
3、當(dāng)一個線程完成任務(wù)時,它會從隊列中取下一個任務(wù)來執(zhí)行。
4、當(dāng)一個線程無事可做,超過一定的時間(keepAliveTime)時,線程池會判斷,如果當(dāng)前運行的線程數(shù)大于 corePoolSize,那么這個線程就被停掉。所以線程池的所有任務(wù)完成后,它最終會收縮到 corePoolSize 的大小。
這樣的過程說明,并不是先加入任務(wù)就一定會先執(zhí)行。假設(shè)隊列大小為 10,corePoolSize 為 3,maximumPoolSize 為 6,那么當(dāng)加入 20 個任務(wù)時,執(zhí)行的順序就是這樣的:首先執(zhí)行任務(wù) 1、2、3,然后任務(wù) 4~13 被放入隊列。這時候隊列滿了,任務(wù) 14、15、16 會被馬上執(zhí)行,而任務(wù) 17~20 則會拋出異常。最終順序是:1、2、3、14、15、16、4、5、6、7、8、9、10、11、12、13。下面是一個線程池使用的例子:
view plaincopy to clipboardprint?
public static void main(String[] args) {
BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.DAYS, queue);
for (int i = 0; i < 20; i++) {
executor.execute(new Runnable() {
public void run() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(String.format("thread %d finished", this.hashCode()));
}
});
}
executor.shutdown();
}
public static void main(String[] args) {
BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.DAYS, queue);
for (int i = 0; i < 20; i++) {
executor.execute(new Runnable() {
public void run() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(String.format("thread %d finished", this.hashCode()));
}
});
}
executor.shutdown();
}
對這個例子的說明如下:
1、BlockingQueue 只是一個接口,常用的實現(xiàn)類有 LinkedBlockingQueue 和 ArrayBlockingQueue。用 LinkedBlockingQueue 的好處在于沒有大小限制。這樣的話,因為隊列不會滿,所以 execute() 不會拋出異常,而線程池中運行的線程數(shù)也永遠(yuǎn)不會超過 corePoolSize 個,keepAliveTime 參數(shù)也就沒有意義了。
2、shutdown() 方法不會阻塞。調(diào)用 shutdown() 方法之后,主線程就馬上結(jié)束了,而線程池會繼續(xù)運行直到所有任務(wù)執(zhí)行完才會停止。如果不調(diào)用 shutdown() 方法,那么線程池會一直保持下去,以便隨時添加新的任務(wù)。
到這里對于這個線程池還只是介紹了一小部分。ThreadPoolExecutor 具有很強的可擴(kuò)展性,不過擴(kuò)展它的前提是要熟悉它的工作方式。后面的文章將會介紹如何擴(kuò)展 ThreadPoolExecutor 類。
本文來自CSDN博客,轉(zhuǎn)載請標(biāo)明出處:http://blog.csdn.net/YidingHe/archive/2009/02/14/3889785.aspx
posted on 2009-08-17 09:49
大鳥 閱讀(435)
評論(1) 編輯 收藏 所屬分類:
JAVA