ExecutorService

ExecutorService / Executor / Executors

ExecutorService

Executor是超类接口,ExecutorService继承了Executor,然后我们常用的类ScheduledThreadPoolExecutor, ThreadPoolExecutor实现了ExecutorService,Executors是工具类,可用于创建ExecutorService的子类。

ThreadPoolExecutor

ExecutorService

几个参数说明:

Core and maximum pool sizes

当一个任务添加后(execute(Runnable r)),如果当前线程池线程数量少于corePoolSize,那么就创建一个新线程来处理,即使已存在的线程是空闲状态。

如果高于corePoolSize,但少于maximumPoolSize,那么会等待在队列workQueue中,如果队列满了,才会新建线程;

所以,如果两个size相等,那么是一个固定大小的线程池;如果maximumPoolSize为Integer.MAX_VALUE,那么会允许任意数量的并发;

一般情况下,这两个值仅在构造函数中设置,不过也可以动态设置。

keepAliveTime

当线程数量大于corePoolSize时,超过的线程会在空闲持续该时间后终止;方法allowCoreThreadTimeOut(boolean) 会把该策略应用到核心线程中;

queue

用于暂存提交的任务;

饱和策略

Abort策略:默认策略,新任务提交时直接抛出未检查的异常RejectedExecutionException,该异常可由调用者捕获。

CallerRuns策略:为调节机制,既不抛弃任务也不抛出异常,而是将某些任务回退到调用者。不会在线程池的线程中执行新的任务,而是在调用exector的线程中运行新的任务。

Discard策略:新提交的任务被抛弃。

总结一下

当提交一个新任务到线程池时首先线程池判断基本线程池(corePoolSize)是否已满?没满,创建一个工作线程来执行任务。满了,则进入下个流程;

其次线程池判断工作队列(workQueue)是否已满?没满,则将新提交的任务存储在工作队列里。满了,则进入下个流程;

最后线程池判断整个线程池(maximumPoolSize)是否已满?没满,则创建一个新的工作线程来执行任务,满了,则交给饱和策略来处理这个任务;

如果线程池中的线程数量大于 corePoolSize 时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过 keepAliveTime,线程也会被终止。

Executors

4种创建

newFixedThreadPool(int nThreads)

固定大小的线程池,无限边界队列

newCachedThreadPool()

可缓存线程池,当有无可用时才会新建线程,如果超过需要,则回收;适用于生存期很短的异步任务;

newScheduledThreadPool(int corePoolSize)

定时线程

newSingleThreadExecutor()

单个工作线程,FIFO

 

 

上一篇:在Java中创建线程池的最佳方法是什么


下一篇:线程池