如何让Java ScheduledExecutorService定时任务遇异常后仍持续执行？

这个问题确实是使用ScheduledExecutorService时很容易踩的坑——默认情况下只要某次任务执行抛了未捕获异常，后续所有调度直接停摆，太坑了！除了在任务里手动加try-catch，还有几个更优雅的通用方案：

1. 给任务套个通用的异常处理包装器 #

最直观的通用方案是写一个工具类，把你的Runnable/Callable任务包一层，统一捕获所有异常。这样不管你提交什么任务，都不用每次手动写重复的try-catch逻辑。

比如写一个SafeRunnable包装类：

public class SafeRunnable implements Runnable {
    private final Runnable delegate;

    public SafeRunnable(Runnable delegate) {
        this.delegate = delegate;
    }

    @Override
    public void run() {
        try {
            delegate.run();
        } catch (Throwable t) {
            // 这里可以替换成日志框架记录、报警等逻辑
            System.err.println("定时任务执行失败，但后续调度会继续: " + t.getMessage());
        }
    }
}

使用的时候把原任务包进去即可：

ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
// 你的业务任务，可能抛出异常
Runnable myBusinessTask = () -> {
    if (Math.random() < 0.5) {
        throw new RuntimeException("模拟任务执行异常");
    }
    System.out.println("任务执行成功");
};
// 提交包装后的任务
executor.scheduleAtFixedRate(new SafeRunnable(myBusinessTask), 0, 1, TimeUnit.SECONDS);

这样哪怕任务抛异常，也只会被包装器捕获，Executor不会感知到异常，后续调度会正常触发。

2. 自定义ThreadFactory，设置全局未捕获异常处理器 #

另一种思路是从线程池的线程入手，给每个线程设置UncaughtExceptionHandler，这样任务抛出的未捕获异常会被这个处理器接住，避免线程因异常直接终止（就算线程终止，线程池也会自动新建线程维持池的大小，后续调度依然能继续）。

比如自定义ThreadFactory：

public class ExceptionHandlingThreadFactory implements ThreadFactory {
    private final ThreadFactory defaultFactory = Executors.defaultThreadFactory();

    @Override
    public Thread newThread(Runnable r) {
        Thread thread = defaultFactory.newThread(r);
        // 设置未捕获异常处理器
        thread.setUncaughtExceptionHandler((threadObj, throwable) -> {
            System.err.println("线程[" + threadObj.getName() + "]遇到未捕获异常: " + throwable.getMessage());
            // 这里可以添加报警、日志持久化等逻辑
        });
        return thread;
    }
}

创建线程池时使用这个自定义工厂：

ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(1, new ExceptionHandlingThreadFactory());
executor.scheduleAtFixedRate(myBusinessTask, 0, 1, TimeUnit.SECONDS);

这种方式不需要修改任务代码，所有提交到这个线程池的任务都会自动被处理异常，适合全局统一配置的场景。

3. 扩展ScheduledThreadPoolExecutor，重写afterExecute方法 #

ThreadPoolExecutor（包括ScheduledThreadPoolExecutor）提供了afterExecute钩子方法，会在每个任务执行完成后被调用——如果任务抛出了异常，这个异常会作为第二个参数传入。我们可以重写这个方法来捕获并处理异常，避免异常传播导致调度停止。

比如自定义 resilient 版的Executor：

public class ResilientScheduledExecutor extends ScheduledThreadPoolExecutor {
    public ResilientScheduledExecutor(int corePoolSize) {
        super(corePoolSize);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t != null) {
            System.err.println("任务执行失败，后续调度将继续: " + t.getMessage());
            // 这里还可以加额外逻辑，比如临时重试一次当前任务
        }
    }
}

使用时直接实例化这个自定义Executor：

ScheduledExecutorService executor = new ResilientScheduledExecutor(1);
executor.scheduleAtFixedRate(myBusinessTask, 0, 1, TimeUnit.SECONDS);

这种方式最贴合Executor的扩展机制，属于从线程池层面统一处理异常，非常优雅。

内容的提问来源于stack exchange，提问作者PNS