Java线程池ThreadPoolExecutor初略探索

在操作系统中，线程是一个非常重要的资源，频繁创建和销毁大量线程会大大降低系统性能。Java线程池原理类似于数据库连接池，目的就是帮助我们实现线程复用，减少频繁创建和销毁线程

ThreadPoolExecutor

ThreadPoolExecutor是线程池的核心类。首先看一下如何创建一个ThreadPoolExecutor。下面是ThreadPoolExecutor常用的一个构造方法：

构造方法

public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
if (corePoolSize < 0 ||
maximumPoolSize <= 0 ||
maximumPoolSize < corePoolSize ||
keepAliveTime < 0)
throw new IllegalArgumentException();
if (workQueue == null || threadFactory == null || handler == null)
throw new NullPointerException();
this.acc = System.getSecurityManager() == null ?
null :
AccessController.getContext();
this.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.workQueue = workQueue;
this.keepAliveTime = unit.toNanos(keepAliveTime);
this.threadFactory = threadFactory;
this.handler = handler;
}

使用案例

/**
* 阻塞的线程池
*/
private ThreadPoolExecutor executor = new ThreadPoolExecutor(
0,      // corePoolSize：线程池维护线程的最少数量
4,      // maximumPoolSize：线程池维护线程的最大数量
10000,  // keepAliveTime：线程池维护线程所允许的空闲时间
TimeUnit.MILLISECONDS,          // unite：线程池维护线程所允许的空闲时间的单位
new LinkedBlockingQueue<>(200), // workQueue：线程池所使用的缓冲队列
new CallerBlockedPolicy()       // handler：线程池对拒绝任务的处理策略，自定义拓展
);

构造方法参数说明

• corePoolSize：核心线程数量，当有新任务在

  execute()

  方法提交时，会执行以下判断： 如果运行的线程少于

  corePoolSize

  ，则创建新线程来处理任务，即使线程池中的其他线程是空闲的；
• 如果线程池中的 1b4e 线程数量大于等于

  corePoolSize

  且小于

  maximumPoolSize

  ，则只有当

  workQueue

  满时才创建新的线程去处理任务；
• 如果设置的

  corePoolSize

  和

  maximumPoolSize

  相同，则创建的线程池的大小是固定的，这时如果有新任务提交，若

  workQueue

  未满，则将请求放入

  workQueue

  中，等待有空闲的线程去从

  workQueue

  中取任务并处理；
• 如果运行的线程数量大于等于maximumPoolSize，这时如果workQueue已经满了，则通过handler所指定的策略来处理任务；
  所以，任务提交时，判断的顺序为 corePoolSize –> workQueue –> maximumPoolSize。

corePoolSize

Worker

corePoolSize

keepAliveTime

Executors.defaultThreadFactory()

RejectedExecutionHandler