// 錯誤示范：Executors默認(rèn)使用無界隊列LinkedBlockingQueue
ExecutorService pool = Executors.newFixedThreadPool(10); 

// 錯誤示范：CachedThreadPool允許創(chuàng)建無限線程
ExecutorService pool = Executors.newCachedThreadPool(); 

// 錯誤示范：默認(rèn)拒絕策略AbortPolicy會拋出異常
pool.execute(() -> { /* 任務(wù)邏輯 */ }); 

new ThreadPoolExecutor(
    8,                          // 核心線程數(shù)：固定服務(wù)員數(shù)量
    16,                         // 最大線程數(shù)：最多可同時工作的服務(wù)員數(shù)量
    30,                         // 臨時線程存活時間：臨時服務(wù)員空閑30秒后下班
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(500), // 任務(wù)隊列：最多存放500個待處理訂單
    new ThreadFactoryBuilder()
        .setNameFormat("餐廳-%d號服務(wù)員") // 給每個服務(wù)員起名字
        .build(),
    new ThreadPoolExecutor.CallerRunsPolicy() // 拒絕策略：讓顧客自己處理訂單（減緩提交壓力）
);

// 錯誤示范：每次調(diào)用方法都新建線程池
public void process() {
    ExecutorService pool = Executors.newSingleThreadExecutor(); // 錯誤！
    pool.execute(...);
}

// 正確示范：分階段關(guān)閉線程池
pool.shutdown(); // 拒絕新任務(wù)，等待已提交任務(wù)執(zhí)行完畢
try {
    if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { // 超時強(qiáng)制關(guān)閉
        pool.shutdownNow(); // 中斷未執(zhí)行任務(wù)
    }
} catch (InterruptedException e) {
    pool.shutdownNow();
}

// 實時監(jiān)控線程池狀態(tài)
int activeThreads = pool.getActiveCount(); // 正在工作的服務(wù)員數(shù)量
long completedTasks = pool.getCompletedTaskCount(); // 已處理訂單數(shù)
int queueSize = ((ThreadPoolExecutor) pool).getQueue().size(); // 待處理訂單數(shù)

// 正確示范：在任務(wù)中捕獲異常
pool.execute(() -> {
    try {
        // 業(yè)務(wù)邏輯
    } catch (Exception e) {
        System.err.println("任務(wù)執(zhí)行失敗：" + e.getMessage());
    }
});

// 正確示范：為線程命名
ThreadFactory factory = new ThreadFactoryBuilder()
    .setNameFormat("訂單處理線程-%d")
    .setUncaughtExceptionHandler((t, e) -> 
        System.err.println("線程" + t.getName() + "出錯：" + e))
    .build();

// 自定義線程池（IO密集型任務(wù)）
ThreadPoolExecutor pool = new ThreadPoolExecutor(
    8,                          // 核心線程數(shù)：8個固定服務(wù)員
    16,                         // 最大線程數(shù)：高峰期最多16個服務(wù)員
    30,                         // 臨時線程存活時間：30秒
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(500), // 訂單隊列最多存500個
    new ThreadFactoryBuilder()
        .setNameFormat("餐廳-%d號服務(wù)員")
        .build(),
    new ThreadPoolExecutor.CallerRunsPolicy() // 顧客自己處理訂單
);

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

// 優(yōu)雅關(guān)閉
pool.shutdown();