自定义线程池-ExecutorBuilder
  # 由来
在JDK中,提供了Executors用于创建自定义的线程池对象ExecutorService,但是考虑到线程池中存在众多概念,这些概念通过不同的搭配实现灵活的线程管理策略,单独使用Executors无法满足需求,构建了ExecutorBuilder。
# 概念
corePoolSize初始池大小maxPoolSize最大池大小(允许同时执行的最大线程数)workQueue队列,用于存在未执行的线程handler当线程阻塞(block)时的异常处理器,所谓线程阻塞即线程池和等待队列已满,无法处理线程时采取的策略
# 线程池对待线程的策略
- 如果池中任务数 < corePoolSize -> 放入立即执行
 - 如果池中任务数 > corePoolSize -> 放入队列等待
 - 队列满 -> 新建线程立即执行
 - 执行中的线程 > maxPoolSize -> 触发handler(RejectedExecutionHandler)异常
 
# workQueue线程池策略
SynchronousQueue它将任务直接提交给线程而不保持它们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略LinkedBlockingQueue默认无界队列,当运行线程大于corePoolSize时始终放入此队列,此时maxPoolSize无效。当构造LinkedBlockingQueue对象时传入参数,变为有界队列,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略ArrayBlockingQueue有界队列,相对无界队列有利于控制队列大小,队列满时,运行线程小于maxPoolSize时会创建新线程,否则触发异常策略
# 使用
- 默认线程池
 
策略如下:
- 初始线程数为corePoolSize指定的大小
 - 没有最大线程数限制
 - 默认使用LinkedBlockingQueue,默认队列大小为1024(最大等待数1024)
 - 当运行线程大于corePoolSize放入队列,队列满后抛出异常
 
ExecutorService executor = ExecutorBuilder builder = ExecutorBuilder.create()..build();
- 单线程线程池
 
- 初始线程数为 1
 - 最大线程数为 1
 - 默认使用LinkedBlockingQueue,默认队列大小为1024
 - 同时只允许一个线程工作,剩余放入队列等待,等待数超过1024报错
 
ExecutorService executor = ExecutorBuilder.create()//
	.setCorePoolSize(1)//
	.setMaxPoolSize(1)//
	.setKeepAliveTime(0)//
	.build();
- 更多选项的线程池
 
- 初始5个线程
 - 最大10个线程
 - 有界等待队列,最大等待数是100
 
ExecutorService executor = ExecutorBuilder.create()
	.setCorePoolSize(5)
	.setMaxPoolSize(10)
	.setWorkQueue(new LinkedBlockingQueue<>(100))
	.build();
- 特殊策略的线程池
 
- 初始5个线程
 - 最大10个线程
 - 它将任务直接提交给线程而不保持它们。当运行线程小于maxPoolSize时会创建新线程,否则触发异常策略
 
ExecutorService executor = ExecutorBuilder.create()
	.setCorePoolSize(5)
	.setMaxPoolSize(10)
	.useSynchronousQueue()
	.build();
上次更新: 2023/05/08, 01:55:50