自定义线程池

线程池的关闭有点问题
//自定义线程池
public class MyThreadPool {
private int poolSize; //当前线程数
private int corePoolSize; //线程数
private int maxPoolSize; //最大线程数
private int queueSize; //任务数
private BlockingQueue<runnable> queue; //任务队列
private int kxseconds; //线程空闲多少秒之后，中断所有线程
//拒绝策略：任务队列满，阻塞加入队列（不加入，直到队列有空的位置）.线程池自动扩容
private boolean isrunning;
private AtomicInteger num = new AtomicInteger();
private CopyOnWriteArrayList<thread> threads = new CopyOnWriteArrayList<thread>();

public MyThreadPool(int corePoolSize,int maxPoolSize,int queueSize,int kxseconds){
this.poolSize = 0; //当前线程数
this.corePoolSize=corePoolSize; //线程数
this.maxPoolSize=maxPoolSize; //最大线程数
this.queueSize=queueSize; //任务数
queue=new ArrayBlockingQueue<runnable>(queueSize); //任务队列
this.kxseconds=kxseconds; //线程空闲多少秒之后，中断所有线程
this.isrunning = true; //线程池启动
new ClearThread().start();
}
public static void main(String[] args)throws Exception {
int corePoolSize = 2;
int maxPoolSize=8;
int queueSize=20;
int kxseconds=60;
MyThreadPool pool = new MyThreadPool(corePoolSize,maxPoolSize, queueSize, kxseconds);
Thread t1 = pool.test(pool);
t1.start();
Thread t2 = pool.test(pool);
t2.start();
Thread.sleep(30*1000);
//pool.close();
}

Thread test(final MyThreadPool pool){
return new Thread(){
public void run(){
Print task = null;
for(int i=1;i可执行->执行->阻塞->终止
void newThread(){
Thread t = new Thread(new Worker());
threads.add(t);
t.start();
poolSize++;
System.out.println("thread " + poolSize);
}
//关闭线程池
void close(){
//this.isrunning = false;
}
private class Worker implements Runnable{
public void run(){
try {
while(isrunning&&!Thread.currentThread().isInterrupted()){
Runnable task = queue.take();
if(task!=null)
task.run();
System.out.println("队列大小："+queue.size());
Thread.sleep(100);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

class Print implements Runnable{
public void run() {
System.out.println(num.incrementAndGet()+": "+queue.size());
}
}
class ClearThread extends Thread{
public ClearThread(){
super("threadpool-clear");
setDaemon(true); //主线程结束，ClearThread线程也自动结束
}
public void run(){
int num = corePoolSize-poolSize;
for(int i=0;i<num newthread try for if>=queueSize*0.8 && poolSize<maxpoolsize newthread if>=corePoolSize){
for(int i=0;i<poolsize-corepoolsize system.out.println threads.get thread.currentthread catch e e.printstacktrace></poolsize-corepoolsize></maxpoolsize></num></runnable></thread></thread></runnable>