技术标签: java exectorpool
java线程池ThreadPoolExector源码分析
今天研究了下ThreadPoolExector源码,大致上总结了以下几点跟大家分享下:
一、ThreadPoolExector几个主要变量
先了解下ThreadPoolExector中比较重要的几个变量。
corePoolSize:核心线程数量
maximumPoolSize:最大线程数量
allowCoreThreadTimeOut:是否允许线程超时(设置为true时与keepAliveTime,TimeUnit一起起作用)
keepAliveTime:线程存活时间(当线程池允许线程超时且运行中的线程数量超过corePoolSize时,会按照此变量设置时间关闭线程)
TimeUnit:单位(一般与keepAliveTime同时使用,供线程池判断是否满足关闭线程的条件)
workQueue:缓冲队列
RejectedExecutionHandler:拒绝处理任务类(默认:AbortPolicy 会抛异常,见下方实例)。
threadFactory:线程工厂(默认:DefaultThreadFactory)
二、线程池的几个主要方法分析
1 主方法:ThreadPoolExector的execute
public void execute(Runnable command) {if (command ==null)
thrownew NullPointerException();
intc=ctl.get();
//1当前运行的线程数量小于核心线程数量,直接将任务加入worker启动运行。if (workerCountOf(c)
c=ctl.get();
} //2 运行线程数量大于核心线程数量时,上面的if分支针对大于corePoolSize,并且缓存队列加入任务操作成功的情况。
运行中并且将任务加入缓冲队列成功,正常来说这样已经完成了处理逻辑。
但是为了保险起见,增加了状态出现异常的确认判断,如果状态出现异常会继续remove操作,如果执行true,则按照拒绝处理策略驳回任务;if (isRunning(c) &&workQueue.offer(command)) {
intrecheck=ctl.get();if (!isRunning(recheck) &&remove(command))
reject(command);
elseif (workerCountOf(recheck)== 0)
addWorker(null,false);
}
//3这里针对运行线程数量超过了corePoolSize,并且缓存队列也已经放满的情况。 注意第二个参数是false,可以在下面addWorker方法看到,就是针对线程池最大线程数量maximumPoolSize的判断。
elseif (!addWorker(command,false))
reject(command);
}
2 关键方法:ThreadPoolExector的addWorker(增加工作线程)
private boolean addWorker(Runnable firstTask, booleancore) {
retry:for(;;) {int c =ctl.get();int rs =runStateOf(c);//Check if queue empty only if necessary.
if (rs >= SHUTDOWN &&
! (rs == SHUTDOWN &&firstTask== null &&
!workQueue.isEmpty()))return false;for(;;) {int wc =workerCountOf(c);if (wc >= CAPACITY ||wc>= (core ?corePoolSize : maximumPoolSize))return false;if(compareAndIncrementWorkerCount(c))breakretry;
c= ctl.get(); //Re-read ctl
if (runStateOf(c) !=rs)continueretry;//else CAS failed due to workerCount change; retry inner loop
}
}boolean workerStarted = false;boolean workerAdded = false;
Worker w= null;try{
w= newWorker(firstTask);final Thread t =w.thread;if (t != null) {final ReentrantLock mainLock = this.mainLock;
mainLock.lock();try{//Recheck while holding lock.//Back out on ThreadFactory failure or if//shut down before lock acquired.
int rs =runStateOf(ctl.get());if (rs < SHUTDOWN ||(rs== SHUTDOWN && firstTask == null)) {if (t.isAlive()) //precheck that t is startable
throw newIllegalThreadStateException();
workers.add(w);int s =workers.size();if (s >largestPoolSize)
largestPoolSize=s;
workerAdded= true;
}
}finally{
mainLock.unlock();
}if(workerAdded) {
t.start();
workerStarted= true;
}
}
}finally{if (!workerStarted)
addWorkerFailed(w);
}returnworkerStarted;
}
3 Worker中的runWorker方法,也是worker中的run方法主体。
public voidrun() {
runWorker(this);
}
final voidrunWorker(Worker w) {
Thread wt=Thread.currentThread();
Runnable task=w.firstTask;
w.firstTask= null;
w.unlock();//allow interrupts
boolean completedAbruptly = true;try{
//执行任务,并且当执行完后再去获取新的task继续执行,getTask方法是由ThreadPoolExecutor提供,继续向下看。while (task != null || (task = getTask()) != null) {
w.lock();//If pool is stopping, ensure thread is interrupted;//if not, ensure thread is not interrupted. This//requires a recheck in second case to deal with//shutdownNow race while clearing interrupt
if ((runStateAtLeast(ctl.get(), STOP) ||(Thread.interrupted()&&runStateAtLeast(ctl.get(), STOP)))&&
!wt.isInterrupted())
wt.interrupt();try{
beforeExecute(wt, task);
Throwable thrown= null;try{
task.run();
}catch(RuntimeException x) {
thrown= x; throwx;
}catch(Error x) {
thrown= x; throwx;
}catch(Throwable x) {
thrown= x; throw newError(x);
}finally{
afterExecute(task, thrown);
}
}finally{
task= null;
w.completedTasks++;
w.unlock();
}
}
completedAbruptly= false;
}finally{
processWorkerExit(w, completedAbruptly);
}
}
privateRunnable getTask() {boolean timedOut = false; //Did the last poll() time out?
for(;;) {int c =ctl.get();int rs =runStateOf(c);//Check if queue empty only if necessary.
if (rs >= SHUTDOWN && (rs >= STOP ||workQueue.isEmpty())) {
decrementWorkerCount();return null;
}int wc =workerCountOf(c);//Are workers subject to culling?
boolean timed = allowCoreThreadTimeOut || wc >corePoolSize;
//如果运行线程数超过了最大线程数,但是缓存队列已经空了,这时递减worker数量。
//如果有设置允许线程超时或者线程数量超过了核心线程数量,并且线程在规定时间内均未poll到任务且队列为空则递减worker数量if ((wc > maximumPoolSize || (timed &&timedOut))&& (wc > 1 ||workQueue.isEmpty())) {if(compareAndDecrementWorkerCount(c))return null;continue;
}try{
Runnable r= timed ?workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
workQueue.take();if (r != null)returnr;
timedOut= true;
}catch(InterruptedException retry) {
timedOut= false;
}
}
}
三、测试实例:
importjava.util.concurrent.BlockingQueue;importjava.util.concurrent.LinkedBlockingQueue;importjava.util.concurrent.ThreadPoolExecutor;importjava.util.concurrent.TimeUnit;public classThreadPoolTest {//核心线程数量
private static int corePoolSize = 3;//最大线程数量
private static int maxPoolSize = 5;//线程存活时间:当线程数量超过corePoolSize时,10秒钟空闲即关闭线程
private static int keepAliveTime = 10000;//缓冲队列
private static BlockingQueue workQueue = null;//线程池
private static ThreadPoolExecutor threadPoolExecutor = null;static{
workQueue= new LinkedBlockingQueue(5);
threadPoolExecutor= newThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
workQueue);
}public static void main(String[] args) throwsInterruptedException {try{for (int i = 0; i < 200; i++) {
System.out.println("=========第" + i + "次");
threadPoolExecutor.execute(newMyTask());
System.out.println("线程池中正在执行的线程数量:" +threadPoolExecutor.getPoolSize());
System.out.println("线程池缓存的任务队列数量:" +threadPoolExecutor.getQueue().size());
}
}finally{
threadPoolExecutor.shutdown();
}
}
}
运行结果:
=========第0次
线程池中正在执行的线程数量:1
线程池缓存的任务队列数量:0
=========第1次
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:2
线程池缓存的任务队列数量:0
正在执行任务:pool-1-thread-2
=========第2次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第3次
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3 由于corePoolSize已经满了,所以开始放缓冲队列
线程池缓存的任务队列数量:1
=========第4次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第5次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
=========第6次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第7次
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
=========第8次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第9次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第10次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第11次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
=========第12次
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第13次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-3
执行完毕:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第14次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第15次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第16次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第17次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-3
线程池缓存的任务队列数量:0
=========第18次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-2
=========第19次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-1
线程池缓存的任务队列数量:0
=========第20次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第21次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第22次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第23次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第24次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-2
=========第25次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-1
线程池缓存的任务队列数量:0
=========第26次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第27次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第28次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第29次
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第30次
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-2
线程池缓存的任务队列数量:1
=========第31次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第32次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第33次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-3
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-1
线程池缓存的任务队列数量:1
=========第34次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第35次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-2
=========第36次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-3
线程池缓存的任务队列数量:0
=========第37次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第38次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第39次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第40次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-3
=========第41次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第42次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第43次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第44次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第45次
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第46次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第47次
执行完毕:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第48次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第49次
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第50次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第51次
执行完毕:pool-1-thread-3
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池缓存的任务队列数量:2
=========第52次
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第53次
执行完毕:pool-1-thread-3
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第54次
执行完毕:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
=========第55次
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-2
=========第56次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第57次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第58次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第59次
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第60次
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第61次
正在执行任务:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-2
=========第62次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第63次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-1
线程池缓存的任务队列数量:0
=========第64次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第65次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第66次
执行完毕:pool-1-thread-2
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第67次
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-1
线程池缓存的任务队列数量:0
=========第68次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-1
=========第69次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第70次
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第71次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第72次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第73次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第74次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第75次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第76次
正在执行任务:pool-1-thread-1
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第77次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第78次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第79次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第80次
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第81次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第82次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第83次
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第84次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
=========第85次
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第86次
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第87次
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
=========第88次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第89次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第90次
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第91次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第92次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第93次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-1
=========第94次
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-3
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第95次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第96次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第97次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第98次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
=========第99次
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第100次
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
=========第101次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第102次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-3
线程池缓存的任务队列数量:0
=========第103次
线程池中正在执行的线程数量:3
正在执行任务:pool-1-thread-2
线程池缓存的任务队列数量:0
=========第104次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
=========第105次
执行完毕:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第106次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第107次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:0
=========第108次
正在执行任务:pool-1-thread-1
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:1
=========第109次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第110次
正在执行任务:pool-1-thread-3
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:2
=========第111次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
=========第112次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第113次
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
正在执行任务:pool-1-thread-2
线程池中正在执行的线程数量:3
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池缓存的任务队列数量:3
=========第114次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:3
=========第115次
线程池中正在执行的线程数量:3
线程池缓存的任务队列数量:4
=========第116次
线程池中正在执行的线程数量:3 由于corePoolSize已经满了,并且缓冲队列也满了,所以此时开始增加线程数,之前一直是1,2,3号线程,现在出现4号线程
线程池缓存的任务队列数量:5
=========第117次
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-2
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
线程池中正在执行的线程数量:4
线程池缓存的任务队列数量:2
=========第118次
线程池中正在执行的线程数量:4
线程池缓存的任务队列数量:3
=========第119次
线程池中正在执行的线程数量:4
线程池缓存的任务队列数量:4
=========第120次
线程池中正在执行的线程数量:4
线程池缓存的任务队列数量:5
=========第121次
正在执行任务:pool-1-thread-4
执行完毕:pool-1-thread-1
正在执行任务:pool-1-thread-1
执行完毕:pool-1-thread-2
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-4
正在执行任务:pool-1-thread-4
线程池中正在执行的线程数量:5
线程池缓存的任务队列数量:1
=========第122次
线程池中正在执行的线程数量:5
线程池缓存的任务队列数量:2
正在执行任务:pool-1-thread-5
=========第123次
执行完毕:pool-1-thread-3
线程池中正在执行的线程数量:5
线程池缓存的任务队列数量:2
=========第124次
线程池中正在执行的线程数量:5
线程池缓存的任务队列数量:3
=========第125次
线程池中正在执行的线程数量:5
线程池缓存的任务队列数量:4
=========第126次
线程池中正在执行的线程数量:5
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-2
线程池缓存的任务队列数量:5
=========第127次
线程池中正在执行的线程数量:5 由于已达到maxPoolSize已经满了,并且缓冲队列也达到最大值,所以此时新增的任务被驳回,异常见下方。
线程池缓存的任务队列数量:5
=========第128次
正在执行任务:pool-1-thread-2
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-3
正在执行任务:pool-1-thread-3
执行完毕:pool-1-thread-3
执行完毕:pool-1-thread-1
执行完毕:pool-1-thread-2
执行完毕:pool-1-thread-5
执行完毕:pool-1-thread-4
Exception in thread “main” java.util.concurrent.RejectedExecutionException: Task stone.ripple.util.threadpool.MyTask@42a57993 rejected from java.util.concurrent.ThreadPoolExecutor@75b84c92[Running, pool size = 5, active threads = 5, queued tasks = 5, completed tasks = 118]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
at stone.ripple.util.threadpool.ThreadPoolTest.main(ThreadPoolTest.java:30)
执行中:Thread-1
执行中:Thread-4
执行中:Thread-7
执行中:Thread-8
执行中:Thread-9
执行中:Thread-10
执行中:Thread-11
执行中:Thread-12
执行中:Thread-14
执行中:Thread-16
执行中:Thread-15
执行中:Thread-17
执行中:Thread-18
执行中:Thread-20
执行中:Thread-19
执行中:Thread-21
执行中:Thread-5
执行中:Thread-26
执行中:Thread-0
执行中:Thread-2
执行中:Thread-3
执行中:Thread-25
执行中:Thread-24
执行中:Thread-22
执行中:Thread-23
执行中:Thread-13
执行中:Thread-6
执行中:Thread-29
执行中:Thread-31
执行中:Thread-28
执行中:Thread-30
执行中:Thread-33
执行中:Thread-34
执行中:Thread-27
执行中:Thread-35
执行中:Thread-32
执行中:Thread-38
执行中:Thread-37
执行中:Thread-41
执行中:Thread-39
执行中:Thread-36
执行中:Thread-43
执行中:Thread-44
执行中:Thread-45
执行中:Thread-57
执行中:Thread-46
执行中:Thread-58
执行中:Thread-75
执行中:Thread-47
执行中:Thread-74
执行中:Thread-59
执行中:Thread-48
执行中:Thread-76
执行中:Thread-60
执行中:Thread-49
执行中:Thread-50
执行中:Thread-61
执行中:Thread-62
执行中:Thread-51
执行中:Thread-63
执行中:Thread-53
执行中:Thread-66
执行中:Thread-52
执行中:Thread-77
执行中:Thread-67
执行中:Thread-54
执行中:Thread-68
执行中:Thread-55
执行中:Thread-65
执行中:Thread-56
执行中:Thread-64
执行中:Thread-42
执行中:Thread-69
执行中:Thread-78
执行中:Thread-70
执行中:Thread-72
执行中:Thread-71
执行中:Thread-73
执行中:Thread-40
执行中:Thread-79
执行中:Thread-82
执行中:Thread-83
执行中:Thread-85
执行中:Thread-86
执行中:Thread-88
执行中:Thread-90
执行中:Thread-81
执行中:Thread-80
执行中:Thread-98
执行中:Thread-97
执行中:Thread-100
执行中:Thread-96
执行中:Thread-99
执行中:Thread-94
执行中:Thread-101
执行中:Thread-93
执行中:Thread-110
执行中:Thread-102
执行中:Thread-103
执行中:Thread-109
执行中:Thread-111
执行中:Thread-105
执行中:Thread-113
执行中:Thread-104
执行中:Thread-91
执行中:Thread-112
执行中:Thread-106
执行中:Thread-115
执行中:Thread-114
执行中:Thread-107
执行中:Thread-118
执行中:Thread-117
执行中:Thread-92
执行中:Thread-108
执行中:Thread-89
执行中:Thread-87
执行中:Thread-84
执行中:Thread-95
执行中:Thread-123
执行中:Thread-124
执行中:Thread-125
执行中:Thread-126
执行中:Thread-127
执行中:Thread-122
执行中:Thread-121
执行中:Thread-119
执行中:Thread-120
执行中:Thread-116
四、总结:
1. ThreadPoolExecutor从execute方法进入执行任务,当线程数量小于核心线程数量时,增加worker执行任务;
2. worker进入runWork方法执行,任务执行完成后,会调用getTask获取新任务,如果不能获取到新任务,有以下情况:
【如果已超过corePoolSize并且允许超时,且在规定时间内一直获取不到新任务worker数量会递减;
如果已超过maxPoolSize并且缓存队列为空worker数量会递减;】
如果能获取到新任务以当前线程继续执行任务;
3. 如果execute时发现线程数量已经达到corePoolSize,则会将任务加入缓冲队列;
4. 如果excute时发现corePoolSize已经达到最大值,并且缓冲队列也已经达到最大值,则会增加worker,直到maxPoolSize。
5. 如果excute时发现maxPoolSize已达最大值,并且缓冲队列也已达到最大值,则会拒绝任务。
文章浏览阅读645次。这个肯定是末尾的IDAT了,因为IDAT必须要满了才会开始一下个IDAT,这个明显就是末尾的IDAT了。,对应下面的create_head()代码。,对应下面的create_tail()代码。不要考虑爆破,我已经试了一下,太多情况了。题目来源:UNCTF。_攻防世界困难模式攻略图文
文章浏览阅读2.9k次,点赞3次,收藏10次。偶尔会用到,记录、分享。1. 数据库导出1.1 切换到dmdba用户su - dmdba1.2 进入达梦数据库安装路径的bin目录,执行导库操作 导出语句:./dexp cwy_init/[email protected]:5236 file=cwy_init.dmp log=cwy_init_exp.log 注释: cwy_init/init_123..._达梦数据库导入导出
文章浏览阅读1.9k次。1. 在官网上下载KindEditor文件,可以删掉不需要要到的jsp,asp,asp.net和php文件夹。接着把文件夹放到项目文件目录下。2. 修改html文件,在页面引入js文件:<script type="text/javascript" src="./kindeditor/kindeditor-all.js"></script><script type="text/javascript" src="./kindeditor/lang/zh-CN.js"_kindeditor.js
文章浏览阅读2.3k次,点赞6次,收藏14次。SPI的详情简介不必赘述。假设我们通过SPI发送0xAA,我们的数据线就会变为10101010,通过修改不同的内容,即可修改SPI中0和1的持续时间。比如0xF0即为前半周期为高电平,后半周期为低电平的状态。在SPI的通信模式中,CPHA配置会影响该实验,下图展示了不同采样位置的SPI时序图[1]。CPOL = 0,CPHA = 1:CLK空闲状态 = 低电平,数据在下降沿采样,并在上升沿移出CPOL = 0,CPHA = 0:CLK空闲状态 = 低电平,数据在上升沿采样,并在下降沿移出。_stm32g431cbu6
文章浏览阅读1.2k次,点赞2次,收藏8次。数据链路层习题自测问题1.数据链路(即逻辑链路)与链路(即物理链路)有何区别?“电路接通了”与”数据链路接通了”的区别何在?2.数据链路层中的链路控制包括哪些功能?试讨论数据链路层做成可靠的链路层有哪些优点和缺点。3.网络适配器的作用是什么?网络适配器工作在哪一层?4.数据链路层的三个基本问题(帧定界、透明传输和差错检测)为什么都必须加以解决?5.如果在数据链路层不进行帧定界,会发生什么问题?6.PPP协议的主要特点是什么?为什么PPP不使用帧的编号?PPP适用于什么情况?为什么PPP协议不_接收方收到链路层数据后,使用crc检验后,余数为0,说明链路层的传输时可靠传输
文章浏览阅读587次。软件测试工程师移民加拿大 无证移民,未受过软件工程师的教育(第1部分) (Undocumented Immigrant With No Education to Software Engineer(Part 1))Before I start, I want you to please bear with me on the way I write, I have very little gen...
文章浏览阅读304次。Thinkpad X250笔记本电脑,装的是FreeBSD,进入BIOS修改虚拟化配置(其后可能是误设置了安全开机),保存退出后系统无法启动,显示:secure boot failed ,把自己惊出一身冷汗,因为这台笔记本刚好还没开始做备份.....根据错误提示,到bios里面去找相关配置,在Security里面找到了Secure Boot选项,发现果然被设置为Enabled,将其修改为Disabled ,再开机,终于正常启动了。_安装完系统提示secureboot failure
文章浏览阅读10w+次,点赞93次,收藏352次。1、用strtok函数进行字符串分割原型: char *strtok(char *str, const char *delim);功能:分解字符串为一组字符串。参数说明:str为要分解的字符串,delim为分隔符字符串。返回值:从str开头开始的一个个被分割的串。当没有被分割的串时则返回NULL。其它:strtok函数线程不安全,可以使用strtok_r替代。示例://借助strtok实现split#include <string.h>#include <stdio.h&_c++ 字符串分割
文章浏览阅读2.3k次。1 .高斯日记 大数学家高斯有个好习惯:无论如何都要记日记。他的日记有个与众不同的地方,他从不注明年月日,而是用一个整数代替,比如:4210后来人们知道,那个整数就是日期,它表示那一天是高斯出生后的第几天。这或许也是个好习惯,它时时刻刻提醒着主人:日子又过去一天,还有多少时光可以用于浪费呢?高斯出生于:1777年4月30日。在高斯发现的一个重要定理的日记_2013年第四届c a组蓝桥杯省赛真题解答
文章浏览阅读851次,点赞17次,收藏22次。摘要:本文利用供需算法对核极限学习机(KELM)进行优化,并用于分类。
文章浏览阅读1.1k次。一、系统弱密码登录1、在kali上执行命令行telnet 192.168.26.1292、Login和password都输入msfadmin3、登录成功,进入系统4、测试如下:二、MySQL弱密码登录:1、在kali上执行mysql –h 192.168.26.129 –u root2、登录成功,进入MySQL系统3、测试效果:三、PostgreSQL弱密码登录1、在Kali上执行psql -h 192.168.26.129 –U post..._metasploitable2怎么进入
文章浏览阅读257次。本文将为初学者提供Python学习的详细指南,从Python的历史、基础语法和数据类型到面向对象编程、模块和库的使用。通过本文,您将能够掌握Python编程的核心概念,为今后的编程学习和实践打下坚实基础。_python人工智能开发从入门到精通pdf