线程池通俗的描述就是预先创建若干空闲线程，等到需要用多线程去处理事务的时候去唤醒某些空闲线程执行处理任务，这样就省去了频繁创建线程的时间，因为频繁创建线程是要耗费大量的CPU资源的。如果一个应用程序需要频繁地处理大量并发事务，不断的创建销毁线程往往会大大地降低系统的效率，这时候线程池就派上用场了。
本文旨在使用Java语言编写一个通用的线程池。当需要使用线程池处理事务时，只需按照指定规范封装好事务处理对象，然后用已有的线程池对象去自动选择空 闲线程自动调用事务处理对象即可。并实现线程池的动态修改（修改当前线程数，最大线程数等）。下面是实现代码：
//ThreadTask .java
package polarman.threadpool;
/** *//**
*线程任务
*/
public interface ThreadTask ...{
public void run();
}
//PooledThread.java
package polarman.threadpool;
import java.util.Collection; import java.util.Vector;
/** *//**
*接受线程池管理的线程
*/
public class PooledThread extends Thread ...{
protected Vector tasks = new Vector();
protected boolean running = false;
protected boolean stopped = false;
protected boolean paused = false;
protected boolean killed = false;
private ThreadPool pool;
public PooledThread(ThreadPool pool)...{ this.pool = pool;
}
public void putTask(ThreadTask task)...{ tasks.add(task);
}
public void putTasks(ThreadTask[] tasks)...{ for(int i=0; i<tasks.length; i++) this.tasks.add(tasks[i]);
}
public void putTasks(Collection tasks)...{ this.tasks.addAll(tasks);
}
protected ThreadTask popTask()...{ if(tasks.size() > 0) return (ThreadTask)tasks.remove(0);
else
return null;
}
public boolean isRunning()...{
return running;
}
public void stopTasks()...{
stopped = true;
}
public void stopTasksSync()...{
stopTasks();
while(isRunning())...{ try ...{
sleep(5);
} catch (InterruptedException e) ...{
}
}
}
public void pauseTasks()...{
paused = true;
}
public void pauseTasksSync()...{
pauseTasks();
while(isRunning())...{ try ...{
sleep(5);
} catch (InterruptedException e) ...{
}
}
}
public void kill()...{ if(!running)
interrupt();
else
killed = true;
}
public void killSync()...{
kill();
while(isAlive())...{ try ...{
sleep(5);
} catch (InterruptedException e) ...{
}
}
}
public synchronized void startTasks()...{
running = true;
this.notify();
}
public synchronized void run()...{ try...{ while(true)...{ if(!running || tasks.size() == 0)...{ pool.notifyForIdleThread(); //System.out.println(Thread.currentThread().getId() + ": 空闲"); this.wait(); }else...{
ThreadTask task;
while((task = popTask()) != null)...{ task.run(); if(stopped)...{
stopped = false;
if(tasks.size() > 0)...{ tasks.clear(); System.out.println(Thread.currentThread().getId() + ": Tasks are stopped");
break;
}
}
if(paused)...{
paused = false;
if(tasks.size() > 0)...{ System.out.println(Thread.currentThread().getId() + ": Tasks are paused");
break;
}
}
}
running = false;
}
if(killed)...{
killed = false;
break;
}
}
责任编辑：小草
