面试官:听说你很懂线程池?

什么是线程池

就是一种池化技术,类似的还有jdbc连接池,对象池。所谓线程池,就是提前创建一堆线程,放到内存(池子)中,需要的时候取一个出来用。

如上图,最顶层的接口就是Executor,实现ExecutorService接口的类,就是对应的线程池类。

如何创建线程池

用Executors工具类,可以很方便地创建各种线程池。(但是实际开发我们不推荐,阿里巴巴的开发手册严令禁止使用Executors,应该用ThreadPoolExecutor)Executors 类可以创建多种类型的线程池,每种线程池都有不同的特点和适用场景。

(1) FixedThreadPool(固定大小线程池):

  • 使用 Executors.newFixedThreadPool(int nThreads) 方法创建。
  • 具有固定大小的线程池,即线程数量固定不变。
  • 适用于需要控制线程数量的场景,例如服务器端处理请求。

(2) CachedThreadPool(缓存线程池):

  • 使用 Executors.newCachedThreadPool() 方法创建。
  • 具有自动调整线程数量的线程池,根据需要创建新线程,空闲线程会被回收。
  • 适用于执行大量短期异步任务的场景,例如异步IO操作。

(3) SingleThreadPool(单线程线程池):

  • 使用 Executors.newSingleThreadExecutor() 方法创建。
  • 只有一个工作线程的线程池,所有任务按顺序执行。
  • 适用于需要保证顺序执行的任务场景,例如日志处理。

(4) ScheduledThreadPool(定时任务线程池):

  • 使用 Executors.newScheduledThreadPool(int corePoolSize) 方法创建。
  • 具有定时执行任务的功能,可以按固定的频率执行任务。
  • 适用于需要定时执行任务的场景,例如定时任务调度。

(5) WorkStealingPool(工作窃取线程池):

  • 使用 Executors.newWorkStealingPool(int parallelism) 方法创建。
  • 基于ForkJoinPool实现的线程池,每个线程都有自己的任务队列,可以窃取其他线程的任务来执行。
  • 适用于需要处理大量并行任务的场景,例如并行计算任务。

为什么不推荐用Executors创建?

线程池底层原理

我们以ThreadPoolExecutor为例,它是ExecutorService的一种实现。

一般我们根据一个类的构造器,可以看出里面的大致思路:

public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
if (corePoolSize < 0 ||
maximumPoolSize