Java任务调度异常处理技巧

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);

scheduler.scheduleAtFixedRate(() -> {
    try {
        // 业务逻辑
        doTask();
    } catch (Exception e) {
        System.err.println("任务执行失败: " + e.getMessage());
        // 记录日志、告警、重试等
        log.error("调度任务异常", e);
    }
}, 0, 5, TimeUnit.SECONDS);

ThreadFactory threadFactory = r -> {
    Thread t = new Thread(r);
    t.setUncaughtExceptionHandler((thread, exception) -> {
        System.err.println("线程 " + thread.getName() + " 发生未捕获异常: " + exception.getMessage());
        log.error("未捕获异常", exception);
    });
    return t;
};

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2, threadFactory);

public class MyJobListener implements JobListener {
    @Override
    public void jobExecutionVetoed(JobExecutionContext context) {
        log.warn("任务被拒绝执行: " + context.getJobDetail().getKey());
    }

    @Override
    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
        if (jobException != null) {
            log.error("任务执行失败: " + context.getJobDetail().getKey(), jobException);
            // 可触发告警或补偿机制
        }
    }
}