executor.execute(() -> {
    try {
        // 你的業(yè)務(wù)邏輯
    } catch (Exception e) {
        System.err.println("線程 " + Thread.currentThread().getName() + " 發(fā)生異常: " + e.getMessage());
        e.printStackTrace(); // 打印完整堆棧信息
    }
});

// 1. 自定義線程工廠
ThreadFactory factory = r -> {
    Thread t = new Thread(r, "MyPool-Thread-" + threadCounter.incrementAndGet()); // 設(shè)置唯一線程名
    t.setUncaughtExceptionHandler((thread, e) -> {
        System.err.println("線程 " + thread.getName() + " 出現(xiàn)異常: " + e.getMessage());
    });
    return t;
};

// 2. 使用自定義工廠創(chuàng)建線程池
ExecutorService executor = Executors.newFixedThreadPool(5, factory);

Future<?> future = executor.submit(() -> {
    // 可能拋出異常的業(yè)務(wù)邏輯
});

try {
    future.get(); // 此處會(huì)拋出 ExecutionException
} catch (ExecutionException e) {
    Throwable cause = e.getCause(); // 這里獲取到任務(wù)中拋出的原始異常
    System.err.println("任務(wù)執(zhí)行失敗，根本原因: " + cause.getMessage());
} catch (InterruptedException e) {
    // 處理中斷異常
    Thread.currentThread().interrupt();
}

class CustomExecutor extends ThreadPoolExecutor {
    // ... 構(gòu)造器 ...

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        // 如果直接有Throwable，說(shuō)明任務(wù)執(zhí)行過(guò)程中拋出了異常
        if (t != null) {
            String threadName = Thread.currentThread().getName();
            System.out.println("線程 " + threadName + " 執(zhí)行任務(wù)時(shí)異常：" + t);
        }
        // 對(duì)于submit提交的任務(wù)，異常被封裝在Future中，需要額外解包
        if (t == null && r instanceof Future<?>) {
            try {
                Future<?> future = (Future<?>) r;
                if (future.isDone()) {
                    future.get(); // 如果任務(wù)有異常，這里會(huì)拋出ExecutionException
                }
            } catch (ExecutionException e) {
                t = e.getCause();
                System.out.println("線程 " + Thread.currentThread().getName() + " 執(zhí)行Future任務(wù)時(shí)異常：" + t);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}