ExecutorService中几个兄弟说明

ThreadPoolExecutor

主要参数

int corePoolSize

int maximumPoolSize

long keepAliveTime //ideltime 当队列为空时的等待时间，如果超过该时间任然没有新任务，则退出当前线程

BlockingQueue<Runnable> workQueue

当新增一个任务时

如果当前任务数<corePoolSize 则新增一个thread，

如果当前执行线程数>maximumPoolSize，否则加入到workQueue中

FixedThreadPool

corePoolSize=maximumPoolSize

使用LinkedBlockingQueue 无界，缓冲队列

无等待(idel)时间，如果队列为空立即返回

数目固定的线程池，当到达coresize后不会销毁，一直等待

使用问题：

固定的线程数，当有大量任务时，queue可能导致oom

 

cachedThreadPool

最小线程数0，最大线程数Integer.MAX

使用SynchronousQueue 无界 无缓冲 等待队列

元素添加后必须等待其被取出才能继续放入(可以认为缓存值为1的阻塞队列)

当某个线程60秒未被使用则移除,（图一中workQueue.poll等待60秒，超时返回null，则图2中的循环退出，相应worker结束

使用问题：

当前面线程没有结束时，会一直创建新线程一直到Integer.MAX,然后queue进入等待

一般情况线程数太多会句柄溢出，内存溢出

线程池伸缩会很厉害，极限范围0—Integer.MAX

适用于快速失败的情况

 

忽略allowCoreThreadTimeOut(默认false)

如果当前执行线程<=corePoolSize 则会触发queue.take() 一直阻塞（也既是说，当执行线程数小于core线程数时，不会再关闭线程，而是等待）

 

总结ThreadPoolExecutor

新任务先进worker线程工作，当所有worker都在忙，且不能新建worker(当前线程数=maximumPoolSize)时，放入queue，等某个线程空了，自动从queue中获取，继续执行，如果queue为空，则判断（当前线程数<=corePoolSize），成立，则一直等待，否则则等待keepAliveTime后销毁该线程