Java线程池内部任务出异常后如何知道是哪个线程出了异常

executor.execute(() -> {
    try {
        // 你的业务逻辑
    } catch (Exception e) {
        System.err.println("线程 " + Thread.currentThread().getName() + " 发生异常: " + e.getMessage());
        e.printStackTrace(); // 打印完整堆栈信息
    }
});

// 1. 自定义线程工厂
ThreadFactory factory = r -> {
    Thread t = new Thread(r, "MyPool-Thread-" + threadCounter.incrementAndGet()); // 设置唯一线程名
    t.setUncaughtExceptionHandler((thread, e) -> {
        System.err.println("线程 " + thread.getName() + " 出现异常: " + e.getMessage());
    });
    return t;
};

// 2. 使用自定义工厂创建线程池
ExecutorService executor = Executors.newFixedThreadPool(5, factory);

Future<?> future = executor.submit(() -> {
    // 可能抛出异常的业务逻辑
});

try {
    future.get(); // 此处会抛出 ExecutionException
} catch (ExecutionException e) {
    Throwable cause = e.getCause(); // 这里获取到任务中抛出的原始异常
    System.err.println("任务执行失败，根本原因: " + cause.getMessage());
} catch (InterruptedException e) {
    // 处理中断异常
    Thread.currentThread().interrupt();
}

class CustomExecutor extends ThreadPoolExecutor {
    // ... 构造器 ...

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        // 如果直接有Throwable，说明任务执行过程中抛出了异常
        if (t != null) {
            String threadName = Thread.currentThread().getName();
            System.out.println("线程 " + threadName + " 执行任务时异常：" + t);
        }
        // 对于submit提交的任务，异常被封装在Future中，需要额外解包
        if (t == null && r instanceof Future<?>) {
            try {
                Future<?> future = (Future<?>) r;
                if (future.isDone()) {
                    future.get(); // 如果任务有异常，这里会抛出ExecutionException
                }
            } catch (ExecutionException e) {
                t = e.getCause();
                System.out.println("线程 " + Thread.currentThread().getName() + " 执行Future任务时异常：" + t);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}