本篇主要用作链接使用。
线程池的核心就是，当接收到一个任务，需要一个线程去执行时，并不着急创建一个线程，而是先去线程池检查是否有空闲的线程，如果有，则直接使用，如果没有则创建新的线程，然后执行任务。任务执行完成后，也不着急销毁线程，而是将线程放到线程池的空闲队列中，等待下次使用。
首先是线程池的实现。
首先是线程池的实现：
/**
* Created by Joker on 2015/3/7.
*/
public class ThreadPool {
private static ThreadPool instance = null;
//空闲的线程队列
private List<JThread> idleThreads;
//已有的线程总数
private int threadCounter = 0;
private Boolean isShunDown = false;
public ThreadPool() {
//初始化空闲线程队列容量为5
this.idleThreads = new Vector<JThread>(5);
this.threadCounter = 0;
}
private static class SingleTonHolder {
private static ThreadPool threadPool = new ThreadPool();
}
/*单例获得线程池实例*/
public static ThreadPool getInstance() {
return SingleTonHolder.threadPool;
}
public int getThreadCounter() {
return threadCounter;
}
/**
* 将线程放入池中，回收线程
*/
protected synchronized void repool(JThread repoolingThread) {
if (!isShunDown) {
idleThreads.add(repoolingThread);
} else {
repoolingThread.shutDown();
}
}
/**
* 停止池中所有线程
*/
public synchronized void shutDownAll() {
this.isShunDown = true;
for (JThread jThread : idleThreads) {
jThread.shutDown();
}
}
/**
* 执行线程任务
*/
public synchronized void execute(Runnable target) {
this.isShunDown = false;
JThread jThread = null;
/*如果池中有空余线程，直接使用该线程*/
if (idleThreads.size() > 0) {
jThread = idleThreads.get(idleThreads.size() - 1);
//将该线程从池中移除
idleThreads.remove(jThread);
//立即执行该任务
jThread.setTarget(target);
}
/*没有空闲线程，创建新线程*/
else {
threadCounter++;
//创建线程
jThread = new JThread(target, "JThread:" + threadCounter, ThreadPool.this);
jThread.start();
}
}
}
要使用上述线程池，还需要一个永不退出的工作现场与之配合。是一个While循环，手动关闭之前，永不结束，一直等待新的任务进来。 |
