package com.ty.thread;
importjava.util.HashSet;importjava.util.Set;importjava.util.concurrent.BlockingQueue;importjava.util.concurrent.LinkedBlockingQueue;/***@authorTaoyong
* @date 2018年5月17日
* 天下没有难敲的代码！*/
public classThreadPoolExecutor {//维护线程的list
private Set threadList = new HashSet();/** 阻塞队列是线程安全的，主要使用在生产/消费者的场景*/
private BlockingQueueblockingQueue;//线程池的工作线程数
private int poolSize = 0;//线程池的核心容量
private int coreSize = 0;private boolean shutDown = false;public ThreadPoolExecutor(intsize) {this.poolSize =size;
blockingQueue= new LinkedBlockingQueue<>(poolSize);
}public void execute(Task task) throwsInterruptedException {if(shutDown == true) {return;
}if(coreSize
blockingQueue.offer(task);
produceWorker(task);
}else{
blockingQueue.put(task);
}
}private void produceWorker(Task task) throwsInterruptedException {if(task == null) {throw new NullPointerException("非法参数：传入的task对象为空！");
}if(shutDown == true) {return;
}
Thread thread= new Thread(newWorker());
threadList.add(thread);
coreSize++;
thread.start();
}public voidshutDown() {if(threadList == null || threadList.size() == 0) {return;
}
shutDown= true;for(Thread thread: threadList) {
System.out.println(thread.getName()+ " interrupt");
thread.interrupt();
}
}/** 此内部类是实际上的工作线 worker是实现了Runnable接口的实际工作线程，通过while(true)循环从BlockingQueue中取任务执行。
**/
class Worker implementsRunnable {
@Overridepublic voidrun() {while(true && shutDown == false) {try{
blockingQueue.take().doJob();
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
}
}