跳至主要內容

Java并发编程:Executors.newFixedThreadPool

程序猿DD原创JavaJava大约 2 分钟

Java并发编程:Executors.newFixedThreadPool

Executors.newFixedThreadPool 方法用于创建一个固定大小的线程池,适用于需要控制并发线程数量的场景。

目录

  1. newFixedThreadPool概述
  2. 创建固定线程池
  3. 提交任务
  4. 完整示例
  5. 关闭线程池
  6. 总结

1. 概述

newFixedThreadPool 创建的线程池特点:

  • 固定线程数:通过参数指定线程数量
  • 无界队列:未执行的任务在队列中等待
  • 线程复用:线程执行完任务后返回池中

语法

public static ExecutorService newFixedThreadPool(int nThreads)

参数说明:

  • nThreads:线程池中线程的数量

2. 创建固定线程池

ExecutorService executor = Executors.newFixedThreadPool(3); // 创建含3个线程的线程池

3. 提交任务

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) { e.printStackTrace(); }
    });
}

输出示例

任务1由pool-1-thread-1执行
任务2由pool-1-thread-2执行
任务3由pool-1-thread-3执行
任务4由pool-1-thread-1执行
任务5由pool-1-thread-2执行

4. 完整示例

import java.util.concurrent.*;

class Task implements Runnable {
    private final String name;
    public Task(String name) { this.name = name; }
    
    @Override
    public void run() {
        System.out.println("任务" + name + "由" + Thread.currentThread().getName() + "执行");
        try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); }
    }
}

public class FixedThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(3);
        
        for (int i = 1; i <=5; i++) {
            executor.submit(new Task("T" + i));
        }
        
        executor.shutdown();
        try {
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
        }
        System.out.println("所有任务完成");
    }
}

输出

任务T1由pool-1-thread-1执行
任务T2由pool-1-thread-2执行
任务T3由pool-1-thread-3执行
任务T4由pool-1-thread-1执行
任务T5由pool-1-thread-2执行
所有任务完成

5. 关闭线程池

优雅关闭流程

executor.shutdown(); // 不再接受新任务
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) { // 等待60秒
        executor.shutdownNow(); // 强制关闭
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
}

6. 总结

  • 适用场景
    • 需要控制并发线程数的计算密集型任务
    • 防止资源耗尽的场景
  • 优势
    • 线程数量固定,避免上下文切换开销
    • 无界队列自动缓冲任务
  • 注意事项
    • 无界队列可能导致内存溢出
    • 线程数应根据硬件资源合理配置

通过newFixedThreadPool可以有效管理并发线程,提升Java应用的性能和稳定性。

上次编辑于:
贡献者: 程序猿DD