为什么不建议用Executors创建线程池-蒲公英云

为什么不建议用Executors创建线程池

- 日理万妓 2024-04-24 23:02 119阅读 0赞

在Java中，java.util.concurrent.Executors类提供了一些工厂方法来创建线程池，如newFixedThreadPool、newCachedThreadPool等。虽然这些方法提供了快速简便的方式来创建线程池，但它们并不总是推荐使用的最佳实践。主要原因是这些工厂方法通常会使用默认设置创建线程池，这些设置在某些情况下可能导致资源不当使用，甚至引起应用程序性能问题。

以下是不建议使用Executors类方法创建线程池的主要原因：

1. `newFixedThreadPool`和`newSingleThreadExecutor`：

这两个工厂方法创建的线程池有无界的工作队列（LinkedBlockingQueue），这意味着如果任务提交速度超过线程池处理速度，队列会无限增长，最终可能会导致内存耗尽。

示例代码：

ExecutorService executorService = Executors.newFixedThreadPool(10);

源码分析（`newFixedThreadPool`）：

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

在上面的代码中，newFixedThreadPool会创建一个ThreadPoolExecutor，并使用无界的LinkedBlockingQueue作为工作队列。

2. `newCachedThreadPool`和`newScheduledThreadPool`：

newCachedThreadPool创建了一个线程池，其中线程数理论上可以无限增长。当新任务提交到线程池时，如果线程池中所有线程都在执行任务，则会创建一个新的线程，而不是排队。这可能会导致创建大量线程，进而耗尽系统资源。

示例代码：

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

源码分析（`newCachedThreadPool`）：

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

在上面的代码中，newCachedThreadPool使用SynchronousQueue作为工作队列，并允许线程池中线程数量达到Integer.MAX_VALUE（实际上是无界的）。

3. 默认拒绝策略：

Executors类中的线程池默认使用AbortPolicy作为拒绝策略，当任务无法提交给线程池时，会抛出RejectedExecutionException异常。这可能在高负载下导致程序崩溃。

最佳实践：

使用ThreadPoolExecutor的构造函数直接创建线程池，并提供合理的参数，以便于更好地控制线程池行为，避免资源耗尽等问题。

示例代码：

int corePoolSize = 10;
int maximumPoolSize = 20;
long keepAliveTime = 60;
TimeUnit unit = TimeUnit.SECONDS;
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
ThreadFactory threadFactory = Executors.defaultThreadFactory();
RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();
ExecutorService pool = new ThreadPoolExecutor(
    corePoolSize,
    maximumPoolSize,
    keepAliveTime,
    unit,
    workQueue,
    threadFactory,
    handler
);