java实现通用线程池

《java实现通用线程池》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、Java实现通用线程池线程池通俗的描述就是预先创建若干空闲线程，等到需要用多线程去处理事务的时候去唤醒某些空闲线程执行处理任务，这样就省去了频繁创建线程的时间，因为频繁创建线程是要耗费大量的CPU资源的。如果一个应用程序需要频繁地处理大量并发事务，不断的创建销毁线程往往会大大地降低系统的效率，这时候线程池就派上用场了。本文旨在使用Java语言编写一个通用的线程池。当需要使用线程池处理事务时，只需按照指定规范封装好事务处理对象，然后用已有的线程池对象去自动选择空闲线程自动调用事务处理对象即可。并实现线

2、程池的动态修改（修改当前线程数，最大线程数等）。下面是实现代码：//ThreadTask.javapackagepolarman.threadpool;/***线程任务*@authorryang*2006-8-8*/publicinterfaceThreadTask{publicvoidrun();}//PooledThread.javapackagepolarman.threadpool;importjava.util.Collection;importjava.util.Vector;/***接

3、受线程池管理的线程*@authorryang*2006-8-8*/publicclassPooledThreadextendsThread{protectedVectortasks=newVector();protectedbooleanrunning=false;protectedbooleanstopped=false;protectedbooleanpaused=false;protectedbooleankilled=false;privateThreadPoolpool;publicPoo

4、ledThread(ThreadPoolpool){this.pool=pool;}publicvoidputTask(ThreadTasktask){tasks.add(task);}publicvoidputTasks(ThreadTask[]tasks){for(inti=0;i

5、tectedThreadTaskpopTask(){if(tasks.size()>0)return(ThreadTask)tasks.remove(0);elsereturnnull;}publicbooleanisRunning(){returnrunning;}publicvoidstopTasks(){stopped=true;}publicvoidstopTasksSync(){stopTasks();while(isRunning()){try{sleep(5);}catch(Inter

6、ruptedExceptione){}}}publicvoidpauseTasks(){paused=true;}publicvoidpauseTasksSync(){pauseTasks();while(isRunning()){try{sleep(5);}catch(InterruptedExceptione){}}}publicvoidkill(){if(!running)interrupt();elsekilled=true;}publicvoidkillSync(){kill();whil

7、e(isAlive()){try{sleep(5);}catch(InterruptedExceptione){}}}publicsynchronizedvoidstartTasks(){running=true;this.notify();}publicsynchronizedvoidrun(){try{while(true){if(!running

8、

9、tasks.size()==0){pool.notifyForIdleThread();//System.out.println(Thread.c

10、urrentThread().getId()+":空闲");this.wait();}else{ThreadTasktask;while((task=popTask())!=null){task.run();if(stopped){stopped=false;if(tasks.size()>0){tasks.clear();System.out.println(Thread.currentThread().getId()+":Tasksarestopped");bre