java中的executor是什么线程池Executor的4种创建方式-java教程-PHP中文网

java中的executor是什么线程池Executor的4种创建方式

尼克

发布： 2025-06-27 14:31:01

原创

709人浏览过

executor在java中扮演线程管理和任务调度的核心角色，它解耦了任务提交与执行机制。1. newfixedthreadpool创建固定大小线程池，适用于任务数量稳定且对响应时间有要求的场景；2. newcachedthreadpool创建可动态调整大小的线程池，适合处理大量短期任务；3. newsinglethreadexecutor创建单线程池，保证任务顺序执行；4. newscheduledthreadpool创建支持定时和周期性任务的线程池。但不推荐使用executors直接创建线程池，因可能引发oom问题，建议通过threadpoolexecutor自定义，其参数包括核心线程数、最大线程数、空闲线程存活时间、任务队列、线程工厂及拒绝策略。关闭线程池时应优先调用shutdown()并配合awaittermination()确保任务完成，必要时再调用shutdownnow()强制关闭。

java中的executor是什么线程池Executor的4种创建方式

Executor在Java中扮演着线程管理和任务调度的核心角色，它允许我们将任务的提交与任务的执行机制解耦。简单来说，Executor就是一个执行Runnable任务的对象，它隐藏了线程创建和管理的复杂性，让开发者可以专注于业务逻辑。

线程池Executor的4种创建方式

Executors.newFixedThreadPool(int nThreads)

这是最常见的线程池创建方式之一。它创建一个固定大小的线程池，池中的线程数量始终保持不变。如果所有线程都在忙碌，新提交的任务将在队列中等待，直到有线程空闲出来。

立即学习“Java免费学习笔记（深入）”；

优点: 资源消耗可控，响应速度快，适用于任务数量相对稳定，对响应时间有要求的场景。
缺点: 如果任务提交速度远大于处理速度，队列可能会无限增长，导致内存溢出。

ExecutorService executor = Executors.newFixedThreadPool(10);
for (int i = 0; i < 100; i++) {
    executor.execute(() -> {
        try {
            Thread.sleep(100); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Thread: " + Thread.currentThread().getName());
    });
}
executor.shutdown(); // 记得关闭线程池

登录后复制

Executors.newCachedThreadPool()

创建一个可缓存的线程池。线程池的大小是不固定的，可以根据任务的需要动态调整。如果没有空闲线程，则创建新的线程；如果线程空闲时间超过一定阈值（默认60秒），则会被回收。

优点: 可以充分利用系统资源，处理大量短期任务。
缺点: 如果任务提交速度过快，可能会创建大量的线程，导致CPU占用率过高，甚至OOM。不太适合长时间运行且任务量持续较高的场景。

ExecutorService executor = Executors.newCachedThreadPool();
for (int i = 0; i < 100; i++) {
    final int taskNum = i;
    executor.execute(() -> {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Thread: " + Thread.currentThread().getName() + ", Task: " + taskNum);
    });
}
executor.shutdown();

登录后复制

Executors.newSingleThreadExecutor()

创建一个单线程的Executor。它确保所有的任务都按照提交的顺序依次执行。

优点: 保证任务的顺序执行，避免并发问题。
缺点: 性能较低，不适合处理大量并发任务。

ExecutorService executor = Executors.newSingleThreadExecutor();
for (int i = 0; i < 10; i++) {
    final int taskNum = i;
    executor.execute(() -> {
        System.out.println("Thread: " + Thread.currentThread().getName() + ", Task: " + taskNum);
    });
}
executor.shutdown();

登录后复制

Executors.newScheduledThreadPool(int corePoolSize)

创建一个可以执行延迟任务或定时任务的线程池。

优点: 可以方便地执行定时任务。
缺点: 相对复杂，需要仔细配置参数。

ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);

// 延迟1秒后执行
executor.schedule(() -> {
    System.out.println("Delayed task executed.");
}, 1, TimeUnit.SECONDS);

// 每隔2秒执行一次
executor.scheduleAtFixedRate(() -> {
    System.out.println("Periodic task executed.");
}, 0, 2, TimeUnit.SECONDS);

// 注意：ScheduledExecutorService通常需要手动关闭，否则程序可能不会退出
// executor.shutdown(); //  在适当的时候关闭

登录后复制

如何选择合适的Executor？

选择合适的Executor取决于具体的应用场景。例如，对于CPU密集型任务，可以考虑使用newFixedThreadPool，线程数量设置为CPU核心数+1。对于IO密集型任务，可以使用newCachedThreadPool，让线程池根据需要动态调整大小。如果需要保证任务的顺序执行，可以使用newSingleThreadExecutor。如果需要执行定时任务，可以使用newScheduledThreadPool。

为什么不推荐使用Executors直接创建线程池？

阿里巴巴Java开发手册中建议不要使用Executors创建线程池，而是通过ThreadPoolExecutor的构造方法来创建。这是因为Executors提供的线程池在某些情况下可能会导致OOM。例如，newFixedThreadPool和newSingleThreadExecutor的LinkedBlockingQueue默认长度是Integer.MAX_VALUE，可能会堆积大量的请求，导致OOM。newCachedThreadPool虽然可以动态创建线程，但是如果没有控制好线程的数量，也可能会导致OOM。

ThreadPoolExecutor的参数详解

ThreadPoolExecutor是创建线程池的核心类。它的构造方法如下：

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)

登录后复制

corePoolSize: 核心线程数。线程池中始终保持的线程数量，即使它们是空闲的。
maximumPoolSize: 最大线程数。线程池中允许的最大线程数量。
keepAliveTime: 线程空闲时间。当线程池中的线程数量超过corePoolSize时，多余的空闲线程的存活时间。
unit: keepAliveTime的时间单位。
workQueue: 任务队列。用于保存等待执行的任务。常见的队列类型有LinkedBlockingQueue、ArrayBlockingQueue、SynchronousQueue等。
threadFactory: 线程工厂。用于创建新的线程。
handler: 拒绝策略。当任务队列已满且线程池中的线程数量达到maximumPoolSize时，新提交的任务将被拒绝。常见的拒绝策略有AbortPolicy（抛出异常）、CallerRunsPolicy（由调用者线程执行）、DiscardPolicy（直接丢弃）、DiscardOldestPolicy（丢弃队列中最老的任务）。

如何优雅地关闭线程池？

关闭线程池通常有两种方式：shutdown()和shutdownNow()。

shutdown(): 平滑关闭线程池，不再接受新的任务，但会等待所有已提交的任务执行完毕。
shutdownNow(): 立即关闭线程池，尝试停止所有正在执行的任务，并返回等待执行的任务列表。

建议使用shutdown()方法，给线程池一个优雅关闭的机会。在关闭线程池之后，需要调用awaitTermination()方法等待所有任务执行完毕。

ExecutorService executor = Executors.newFixedThreadPool(10);
// 提交任务...

executor.shutdown(); // 拒绝接受新的任务
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow(); // 超时后强制关闭
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

登录后复制

以上就是java中的executor是什么线程池Executor的4种创建方式的详细内容，更多请关注php中文网其它相关文章！