线程池状态
在ThreadPoolExecutor中定义了一个volatile变量,另外定义了几个static final变量表示线程池的各个状态:
volatile int runState; static final int RUNNING = 0; static final int SHUTDOWN = 1; static final int STOP = 2; static final int TERMINATED = 3;
runState表示当前线程池的状态,它是一个volatile变量用来保证线程之间的可见性;
下面的几个static final变量表示runState可能的几个取值。
当创建线程池后,初始时,线程池处于RUNNING状态;
如果调用了shutdown()方法,则线程池处于SHUTDOWN状态,此时线程池不能够接受新的任务,它会等待所有任务执行完毕;
如果调用了shutdownNow()方法,则线程池处于STOP状态,此时线程池不能接受新的任务,并且会去尝试终止正在执行的任务;
当线程池处于SHUTDOWN或STOP状态,并且所有工作线程已经销毁,任务缓存队列已经清空或执行结束后,线程池被设置为TERMINATED状态
RUNNING:可接收新任务,可执行等待队列里的任务SHUTDOWN:不可接收新任务,可执行等待队列里的任务STOP:不可接收新任务,不可执行等待队列里的任务,并且尝试终止所有在运行任务TIDYING:所有任务已经终止,执行terminated()TERMINATED:terminated()执行完成
调用execute将会根据线程池的情况创建Worker,可以归纳出下图四种情况:
总结一下 针对于 newFixedThreadpool
首先来一个任务,创建一个线程。
当线程数量等于corepoolsize的时候,任务加入到工作队列中。
当工作队列慢的时候,继续增加线程知道maxpoolsize.
当线程数量=maxpoolsize的时候,新来的线程有rejecthandler处理。
rejecthandler有四种策略,
1 直接抛出异常 2 直接丢弃任务 3 丢掉工作队列里面老的任务,接受处理新任务 4 由客户端的线程处理任务