細心!用心!耐心!

線程池也許很多比較陌生 但是提到servlet每個人都知道，servlet就是用線程池來處理請求的
一個線程池由線程池管理器 工作線程 任務(wù)隊列和任務(wù)接口組成
一 線程池管理器---ThreadPoolMananger 主要負責(zé)啟動 停止工作線程

1. public class ThreadPoolManager {   
2.   
3.     private static int DEFAULT_POOL_SIZE = 4;   
4.     private List<WorkThread> threadPool;   
5.     private Queue<Task> taskQueue;   
6.     private int poolSize;   
7.        
8.     public ThreadPoolManager(){   
9.         this(DEFAULT_POOL_SIZE);   
10.     }   
11.        
12.     public ThreadPoolManager(int poolSize){   
13.         if(poolSize <= 0){   
14.             this.poolSize = DEFAULT_POOL_SIZE;   
15.         }else{   
16.             this.poolSize = poolSize;   
17.         }   
18.            
19.         threadPool = new ArrayList<WorkThread>(this.poolSize);   
20.         taskQueue = new ConcurrentLinkedQueue<Task>();   
21.            
22.         startup();   
23.     }   
24.        
25.     /**  
26.      * 啟動線程池 開始處理任務(wù)  
27.      */  
28.     private void startup(){   
29.         System.out.println("啟動工作線程。。。");   
30.         synchronized(taskQueue){   
31.             for(int i = 0; i < DEFAULT_POOL_SIZE; i++){   
32.                 WorkThread workThread = new WorkThread(taskQueue);   
33.                 threadPool.add( workThread );   
34.                 workThread.start();   
35.             }   
36.         }   
37.            
38.     }   
39.        
40.     /**  
41.      * 停止工作線程。工作線程不一定立即停止，只有在線程處于運行狀態(tài)時會立即停止  
42.      */  
43.     public void shutdown(){   
44.         System.out.println("停止工作線程.");   
45.         synchronized(taskQueue){   
46.             for(int i = 0; i < DEFAULT_POOL_SIZE; i++){   
47.                 threadPool.get(i).shutdown();   
48.             }   
49.         }   
50.     }   
51.        
52.     /**  
53.      * 添加消息到隊尾,    
54.      */  
55.     public void addTask(Task task){   
56.         synchronized(taskQueue){   
57.             taskQueue.add(task);   
58.             taskQueue.notifyAll();     
59.         }   
60.     }   
61.   
62. }  

二 工作線程---WorkerThread 顧名思義 它本身就是一個線程，而且是專門用來工作的，工作線程的主要任務(wù)是從任務(wù)隊列中取出任務(wù) 然后執(zhí)行任務(wù)

/**  

 * 工作線程  

 * @author XuLiangYong  

 * Jul 20, 2007 3:47:52 PM  

 */  

public class WorkThread extends Thread{   

    private boolean shutdown = false;   

    private Queue<Task> queue;   

       

    public WorkThread(Queue<Task> queue){   

        this.queue = queue;   

    }   

       

    public void run(){   

        while(!shutdown){   

            synchronized(queue){ //獲得對象鎖 禁止其他線程訪問   

                if(!queue.isEmpty()){   

                    //處理任務(wù)    

                    Task task = queue.poll();   

                    task.execute();   

                }else{   

                    try {   

                        queue.wait(); //釋放鎖 線程處于阻賽狀態(tài) 等待notify喚醒   

                    } catch (InterruptedException e) {   

                    }   

                }   

            }   

        }//end while   

    }   

       

    /**  

     * 調(diào)用該方法后不一定會立即結(jié)束線程， 只有在線程處于運行狀態(tài)且處理完當前任務(wù)后才結(jié)束  

     */  

    public void shutdown(){   

        shutdown = true;   

    }   

}  

 

三 任務(wù)隊列---TaskQueue FIFO數(shù)據(jù)結(jié)構(gòu) 在出對入隊的時候要鎖定對象避免兩個線程重復(fù)處理某任務(wù)
在這里我采用的是java提供的ConcurrentLinkedQueue隊列，這是一個用鏈表實現(xiàn)的隊 可無限的擴大，具體用法請看doc
用到隊列的地方主要有兩個 addTask(Task task) 和 Task task = queue.poll();


四 任務(wù)接口---Task 任務(wù)接口只有一個方法 execute（），使用者只需實現(xiàn)這個接口就可以了

public interface Task {   

    void execute();   

}

用法：

public class TestThreadPoolManager extends TestCase {   

       

    public void test(){   

        ThreadPoolManager pool = new ThreadPoolManager();   

        for(int i = 0; i < 100; i++){   

            pool.addTask(new SimpleTask(new MyManager(), i)); //SimpleTask實現(xiàn)了Task接口   

        }   

        pool.shutdown();   

    }   

       

} 

可以看出用戶的使用非常簡單
在jdk5中 java提供了線程池
有一點注意 千萬不要在servlet中調(diào)用線程池 因為servlet本來就是一個線程池