Java线程池内部任务出异常后发现异常的3种方法

import java.util.concurrent.*;

public class CustomThreadFactoryDemo {
    public static void main(String[] args) {
        ExecutorService executor = new ThreadPoolExecutor(
            2, 4, 0L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue<>(10),
            new CustomThreadFactory()
        );

        executor.execute(() -> {
            throw new RuntimeException("任务异常，测试线程异常处理！");
        });

        executor.shutdown();
    }

    // 自定义 ThreadFactory
    static class CustomThreadFactory implements ThreadFactory {
        private final ThreadFactory defaultFactory = Executors.defaultThreadFactory();

        @Override
        public Thread newThread(Runnable r) {
            Thread thread = defaultFactory.newThread(r);
            thread.setUncaughtExceptionHandler((t, e) -> {
                System.err.println("线程 " + t.getName() + " 出现异常: " + e.getMessage());
            });
            return thread;
        }
    }
}

import java.util.concurrent.*;

public class FutureExceptionHandlingDemo {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(2);

        Future<?> future = executor.submit(() -> {
            throw new RuntimeException("任务执行失败！");
        });

        try {
            future.get(); // get() 方法会抛出异常
        } catch (InterruptedException | ExecutionException e) {
            System.err.println("线程 " + Thread.currentThread().getName() + " 捕获到任务异常: " + e.getCause().getMessage());
        }

        executor.shutdown();
    }
}

import java.util.concurrent.*;

public class TryCatchExceptionHandlingDemo {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(2);

        executor.execute(() -> {
            try {
                throw new RuntimeException("任务崩溃！");
            } catch (Exception e) {
                System.err.println("线程 " + Thread.currentThread().getName() + " 发生异常: " + e.getMessage());
            }
        });

        executor.shutdown();
    }
}