ExecutorService / Executor / Executors
Executor是超类接口,ExecutorService继承了Executor,然后我们常用的类ScheduledThreadPoolExecutor, ThreadPoolExecutor实现了ExecutorService,Executors是工具类,可用于创建ExecutorService的子类。
ThreadPoolExecutor
几个参数说明:
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