執行緒池設計思路
執行緒池的思路和 生產者消費者模型是很接近的。
1. 準備一個任務容器
2. 一次性啟動10個 消費者執行緒
3. 剛開始任務容器是空的，所以執行緒都 wait在上面。
4. 直到一個外部執行緒往這個任務容器中扔了一個“任務”，就會有一個消費者執行緒被喚醒notify
5. 這個消費者執行緒取出“任務”，並且執行這個任務，執行完畢後，繼續等待下一次任務的到來。
6. 如果短時間內，有較多的任務加入，那麼就會有多個執行緒被喚醒，去執行這些任務。
在整個過程中，都不需要建立新的執行緒，而是迴圈使用這些已經存在的執行緒
package maptoxml;
import java.util.LinkedList;
public class ThreadPool {
// 執行緒池大小
int threadPoolSize;
// 任務容器
LinkedList<Runnable> tasks = new LinkedList<Runnable>();
// 試圖消費任務的執行緒
public ThreadPool() {
threadPoolSize = 10;
// 啟動10個任務消費者執行緒
synchronized (tasks) {
for (int i = 0; i < threadPoolSize; i++) {
new TaskConsumeThread("任務消費者執行緒 " + i).start();
}
}
}
public void add(Runnable r) {
synchronized (tasks) {
tasks.add(r);
// 喚醒等待的任務消費者執行緒
tasks.notifyAll();
}
}
class TaskConsumeThread extends Thread {
public TaskConsumeThread(String name) {
super(name);
}
Runnable task;
public void run() {
System.out.println("啟動： " + this.getName());
while (true) {
synchronized (tasks) {
while (tasks.isEmpty()) {
try {
tasks.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
task = tasks.removeLast();
// 允許新增任務的執行緒可以繼續新增任務
tasks.notifyAll();
}
System.out.println(this.getName() + " 獲取到任務，並執行");
task.run();
}
}
}
}
package maptoxml;
public class TestThread {
public static void main(String[] args) {
ThreadPool pool = new ThreadPool();
for (int i = 0; i < 5; i++) {
Runnable task = new Runnable() {
@Override
public void run() {
//System.out.println("執行任務");
//任務可能是列印一句話
//可能是訪問檔案
//可能是做排序
}
};
pool.add(task);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
創造一個情景，每個任務執行的時間都是1秒
剛開始是間隔1秒鐘向執行緒池中新增任務
然後間隔時間越來越短，執行任務的執行緒還沒有來得及結束，新的任務又來了。
就會觀察到執行緒池裡的其他執行緒被喚醒來執行這些任務
package maptoxml;
public class TestThread {
public static void main(String[] args) {
ThreadPool pool = new ThreadPool();
int sleep = 1000;
for (int i = 0; i < 5; i++) {
Runnable task = new Runnable() {
@Override
public void run() {
//System.out.println("執行任務");
//任務可能是列印一句話
//可能是訪問檔案
//可能是做排序
}
};
pool.add(task);
try {
Thread.sleep(sleep);
sleep = sleep>100?sleep-100:sleep;
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}