本篇主要用作链接使用。
线程池的核心就是,当接收到一个任务,需要一个线程去执行时,并不着急创建一个线程,而是先去线程池检查是否有空闲的线程,如果有,则直接使用,如果没有则创建新的线程,然后执行任务。任务执行完成后,也不着急销毁线程,而是将线程放到线程池的空闲队列中,等待下次使用。
首先是线程池的实现。
首先是线程池的实现:
/**
* 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
循环,手动关闭之前,永不结束,一直等待新的任务进来。
该工作线程的实现如下:
/**
* Created by Joker on 2015/3/7.
*/
public class JThread extends Thread {
//线程池
private ThreadPool threadPool;
//任务
private Runnable target;
private boolean isShutDown = false;
private boolean isIdle = false;
public JThread(Runnable target, String name, ThreadPool threadPool) {
super(name);
this.target = target;
this.threadPool = threadPool;
}
public Runnable getTarget() {
return target;
}
public boolean isIdle() {
return isIdle;
}
@Override
public void run() {
//只要没有关闭,则一直不结束该线程
while (!isShutDown) {
isIdle = false;
if (null != target) {
//执行任务,注意这里调用的是run(),而不是start()
target.run();
}
//任务结束,闲置状态
isIdle = true;
try {
threadPool.repool(JThread.this);
synchronized (this) {
//线程空闲,等待新的任务到来
wait();
}
} catch (InterruptedException e) {
}
isIdle = false;
}
}
public synchronized void setTarget(Runnable target) {
this.isShutDown = false;
this.target = target;
//设置任务之后,通知run方法,开始执行任务
notifyAll();
}
/**
* 关闭线程
*/
public synchronized void shutDown() {
this.isShutDown = true;
notifyAll();
}
}
使用方法如下:
ThreadPool.getInstance().execute(new Runnable() {
@Override
public void run() {
/*执行任务*/
}
});
网友评论