Java线程池新手避坑指南

// 错误示范：Executors默认使用无界队列LinkedBlockingQueue
ExecutorService pool = Executors.newFixedThreadPool(10); 

// 错误示范：CachedThreadPool允许创建无限线程
ExecutorService pool = Executors.newCachedThreadPool(); 

// 错误示范：默认拒绝策略AbortPolicy会抛出异常
pool.execute(() -> { /* 任务逻辑 */ }); 

new ThreadPoolExecutor(
    8,                          // 核心线程数：固定服务员数量
    16,                         // 最大线程数：最多可同时工作的服务员数量
    30,                         // 临时线程存活时间：临时服务员空闲30秒后下班
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(500), // 任务队列：最多存放500个待处理订单
    new ThreadFactoryBuilder()
        .setNameFormat("餐厅-%d号服务员") // 给每个服务员起名字
        .build(),
    new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略：让顾客自己处理订单（减缓提交压力）
);

// 错误示范：每次调用方法都新建线程池
public void process() {
    ExecutorService pool = Executors.newSingleThreadExecutor(); // 错误！
    pool.execute(...);
}

// 正确示范：分阶段关闭线程池
pool.shutdown(); // 拒绝新任务，等待已提交任务执行完毕
try {
    if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { // 超时强制关闭
        pool.shutdownNow(); // 中断未执行任务
    }
} catch (InterruptedException e) {
    pool.shutdownNow();
}

// 实时监控线程池状态
int activeThreads = pool.getActiveCount(); // 正在工作的服务员数量
long completedTasks = pool.getCompletedTaskCount(); // 已处理订单数
int queueSize = ((ThreadPoolExecutor) pool).getQueue().size(); // 待处理订单数

// 正确示范：在任务中捕获异常
pool.execute(() -> {
    try {
        // 业务逻辑
    } catch (Exception e) {
        System.err.println("任务执行失败：" + e.getMessage());
    }
});

// 正确示范：为线程命名
ThreadFactory factory = new ThreadFactoryBuilder()
    .setNameFormat("订单处理线程-%d")
    .setUncaughtExceptionHandler((t, e) -> 
        System.err.println("线程" + t.getName() + "出错：" + e))
    .build();

// 自定义线程池（IO密集型任务）
ThreadPoolExecutor pool = new ThreadPoolExecutor(
    8,                          // 核心线程数：8个固定服务员
    16,                         // 最大线程数：高峰期最多16个服务员
    30,                         // 临时线程存活时间：30秒
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(500), // 订单队列最多存500个
    new ThreadFactoryBuilder()
        .setNameFormat("餐厅-%d号服务员")
        .build(),
    new ThreadPoolExecutor.CallerRunsPolicy() // 顾客自己处理订单
);

// 使用示例
for (int i = 0; i < 1000; i++) {
    pool.execute(() -> {
        // 处理订单（模拟IO操作）
        try { Thread.sleep(100); } catch (InterruptedException e) { }
    });
}

// 优雅关闭
pool.shutdown();