一个简单的线程池

1. import java.util.LinkedList;   
2.   
3. public class AppThreadPool {   
4.     private int poolSize;   
5.   
6.     private LinkedList queue;   
7.   
8.     public AppThreadPool(int poolSize) {   
9.         this.poolSize = poolSize;   
10.         queue = new LinkedList();   
11.         FileWorker[] Pool = new FileWorker[poolSize];   
12.         for (int i = 0; i < Pool.length; i++) {   
13.             Pool[i] = new FileWorker();   
14.             Pool[i].start();   
15.         }   
16.     }   
17.   
18.     public void addTask(Runnable r) {   
19.         synchronized (queue) {   
20.             queue.addLast(r);   
21.             queue.notify();   
22.         }   
23.     }   
24.   
25.     public int getSize() {   
26.         return poolSize;   
27.     }   
28.   
29.     private class FileWorker extends Thread {   
30.         public void run() {   
31.             Runnable task;   
32.             while (true) {   
33.                 synchronized (queue) {   
34.                     while (queue.isEmpty()) {   
35.                         try {   
36.                             queue.wait();   
37.                         } catch (InterruptedException e) {   
38.                             e.printStackTrace();   
39.                         }   
40.                     }   
41.                     task = (Runnable) queue.removeFirst();   
42.                 }   
43.                 task.run();   
44.             }   
45.         }   
46.     }   
47.   
48. }