在Java中如何使用ExecutorService实现固定线程池-java教程-PHP中文网

在Java中如何使用ExecutorService实现固定线程池

P粉602998670

发布： 2025-10-20 14:31:01

原创

145人浏览过

答案：Java中通过Executors.newFixedThreadPool(3)创建固定线程池，提交5个任务由3个线程执行，任务超出线程数时进入无界队列等待，使用shutdown()关闭线程池并配合awaitTermination()确保任务完成，避免资源泄漏。

在java中如何使用executorservice实现固定线程池

在Java中，使用 ExecutorService 实现固定线程池非常简单，主要通过 Executors 工具类的 newFixedThreadPool 方法来创建。这种方式可以限制同时运行的线程数量，适用于负载较稳定、任务数量可控的场景。

创建固定线程池

调用 Executors.newFixedThreadPool(int nThreads) 方法即可创建一个指定线程数的线程池：

nThreads 表示核心线程数量，这些线程会一直存活，除非显式关闭线程池
多余的任务会被放入一个无界队列中等待执行

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个包含3个线程的固定线程池
        ExecutorService executor = Executors.newFixedThreadPool(3);

        // 提交5个任务
        for (int i = 1; i <= 5; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("任务 " + taskId + " 正在由线程 " + Thread.currentThread().getName() + " 执行");
                try {
                    Thread.sleep(2000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println("任务 " + taskId + " 完成");
            });
        }

        // 关闭线程池
        executor.shutdown();
        try {
            if (!executor.awaitTermination(60, java.util.concurrent.TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
            Thread.currentThread().interrupt();
        }
    }
}

登录后复制