线程池状态

  在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,可以归纳出下图四种情况:线程池 threadpoolexecutor 学习

总结一下 针对于 newFixedThreadpool

首先来一个任务,创建一个线程。

当线程数量等于corepoolsize的时候,任务加入到工作队列中。

当工作队列慢的时候,继续增加线程知道maxpoolsize.

当线程数量=maxpoolsize的时候,新来的线程有rejecthandler处理。


rejecthandler有四种策略,

1 直接抛出异常 2 直接丢弃任务 3 丢掉工作队列里面老的任务,接受处理新任务 4 由客户端的线程处理任务


相关文章: