java实现的线程池

1. 线程池管理器（ThreadPoolManager）:用于创建并管理线程池
2. 工作线程（WorkThread）:线程池中线程
3. 任务接口（Task）:每个任务必须实现的接口，以供工作线程调度任务的执行。
4. 任务队列:用于存放没有处理的任务。提供一种缓冲机制。
5. 线程池管理器至少有下列功能：创建线程池，销毁线程池，添加新任务创建线程池的部分代码如下：
7. 一共包含三个类：
8. ThreadPool，管理线程池，实现采用单例模式。当来一个新的请求时，就把请求放入任务队列，如果有空闲线程，就唤醒等待在任务队列上的空闲线程，否则看工作线程是否超过限制，如果否，则新建一个线程，否则什么也不做。
9. WorkThread，干活的线程。run()有个while(true)循环，不断的取任务然后执行任务。
10. Request，代表一个任务所有的输入。
12. /*#ThreadPool.java*/
14. packagethreadpool;
16. importjava.util.LinkedList;
18. publicclassThreadPool
19. {
20. publicstaticThreadPoolgetInstance()
21. {
22. if(pool==null)pool=newThreadPool();
23. returnpool;
24. }
26. publicvoidaddTask(Requestrequest)
27. {
28. synchronized(taskList)
29. {
30. taskList.addLast(request);
31. if(freeNum==0)
32. {
33. if(workingNum<maxNum)
34. {
35. freeNum++;
36. (newWorkThread()).start();
37. }
38. }
39. taskList.notifyAll();
40. }
41. }
43. privateThreadPool()
44. {
46. }
48. privatestaticThreadPoolpool;
49. privateintmaxNum=500;
50. intfreeNum=0;
51. intworkingNum=0;
52. LinkedList<Request>taskList=newLinkedList<Request>();
53. }
55. /*#WorkThread.java*/
57. packagethreadpool;
59. publicclassWorkThreadextendsThread
60. {
61. privatestaticThreadPoolpool=ThreadPool.getInstance();
62. privateRequestr;
63. publicvoidrun()
64. {
65. while(true)
66. {
67. try
68. {
69. while(true)
70. {
71. synchronized(pool.taskList)
72. {
73. //gotatask
74. if(pool.taskList.size()>0)
75. {
76. pool.freeNum--;
77. pool.workingNum++;
78. r=pool.taskList.removeFirst();
79. pool.taskList.notifyAll();
80. break;
81. }
82. //waitfortask
83. elsepool.taskList.wait();
84. }
85. }
86. }
87. catch(InterruptedExceptione)
88. {
89. e.printStackTrace();
90. break;
91. }
93. //finishthetask
95. synchronized(pool.taskList)
96. {
97. pool.freeNum++;
98. pool.workingNum--;
99. }
100. }
101. }
102. }
104. /*#Request.java*/
106. packagethreadpool;
108. publicclassRequest
109. {
111. }