Java 定時任務三大實現方案對比：Timer、ScheduledExecutorService、Spring Task 選型指南

Java 定時任務三大實現方案對比：Timer、ScheduledExecutorService、Spring Task 選型指南

Java 中實現定時任務主要有三種原生/框架級方案：java.util.Timer、ScheduledExecutorService、Spring Task (@Scheduled)。本文對比其原理、優缺點、適用場景與最佳實踐，助你精準選型。

方案對比總覽

方案一：java.util.Timer (不推薦生產使用)

基本用法

Timer timer = new Timer(true); // daemon 線程, JVM 退出自動結束
TimerTask task = new TimerTask() {
    @Override public void run() {
        System.out.println("任務執行: " + new Date());
    }
};
// 固定頻率: 首次延遲 1秒, 之後每 2秒執行
timer.scheduleAtFixedRate(task, 1000, 2000);
// 固定延遲: 上次執行結束後延遲 2秒
timer.schedule(task, 1000, 2000);
// 指定時間單次執行
timer.schedule(task, new Date(System.currentTimeMillis() + 5000));

致命缺陷

1. 單線程串行：任務執行時間超過間隔，後續任務排隊延遲
2. 異常吞噬：任務拋出未捕獲異常 → Timer 線程死亡 → 所有已排程任務永久停止，無任何日誌預警
3. 系統時間敏感：依賴 System.currentTimeMillis()，系統時間修改導致調度錯亂
4. 無動態管理：運行中無法新增/修改任務，只能 cancel() 整個 Timer

適用場景

• 簡單測試、原型驗證、非關鍵業務、單次延遲任務

方案二：ScheduledExecutorService (推薦原生基礎設施)

基本用法

// 創建線程池 (核心線程數 = 並發任務數)
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(4);

// 1. 固定頻率 (執行開始時間間隔固定, 可能並行)
scheduler.scheduleAtFixedRate(() -> {
    System.out.println("FixedRate: " + System.currentTimeMillis());
}, 1, 2, TimeUnit.SECONDS);

// 2. 固定延遲 (上次結束到下次開始間隔固定, 串行)
scheduler.scheduleWithFixedDelay(() -> {
    try { Thread.sleep(3000); } catch (InterruptedException e) {}
    System.out.println("FixedDelay: " + System.currentTimeMillis());
}, 1, 2, TimeUnit.SECONDS);

// 3. 單次延遲執行
ScheduledFuture future = scheduler.schedule(() -> {
    System.out.println("One-shot: " + System.currentTimeMillis());
}, 5, TimeUnit.SECONDS);

// 4. Cron 表達式 (需引入 Quartz 或自行解析, JDK 原生不支持)
// 推薦: CronExpression (Quartz) 或 Spring CronSequenceGenerator

// 關閉
scheduler.shutdown(); // 優雅關閉: 不接受新任務, 等待進行中任務完成
// scheduler.shutdownNow(); // 強制關閉: 嘗試中斷執行中任務

核心優勢

• 線程池隔離：核心線程數可配置，任務並行執行
• 異常隔離：單任務異常不影響線程池其他任務
• Future 控制：future.cancel(true) 可中斷特定任務
• 靈活提交：運行時動態 schedule/submit 新任務

最佳實踐

// 生產環境推薦: 自定義 ThreadFactory + 拒絕策略 + 監控
ThreadFactory factory = new ThreadFactoryBuilder()
    .setNameFormat("scheduler-%d")
    .setDaemon(true)
    .setUncaughtExceptionHandler((t, e) -> log.error("Scheduler task failed", e))
    .build();

ScheduledExecutorService scheduler = new ScheduledThreadPoolExecutor(
    4, factory, new ThreadPoolExecutor.AbortPolicy() // 或 CallerRunsPolicy
);

// 關鍵: 添加 JVM 關閉鉤子優雅停機
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    scheduler.shutdown();
    try { scheduler.awaitTermination(30, TimeUnit.SECONDS); }
    catch (InterruptedException e) { scheduler.shutdownNow(); }
}));

方案三：Spring Task @Scheduled (推薦 Spring 生態首選)

啟用配置

@Configuration
@EnableScheduling // 關鍵註解
public class SchedulerConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar registrar) {
        // 自定義線程池 (替換默認單線程)
        registrar.setTaskScheduler(taskScheduler());
    }

    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(10); // 核心線程數
        scheduler.setThreadNamePrefix("spring-scheduler-");
        scheduler.setDaemon(true);
        scheduler.setErrorHandler(t -> log.error("Scheduled task error", t));
        scheduler.setRemoveOnCancelPolicy(true); // 取消時從隊列移除
        return scheduler;
    }
}

註解用法

@Service
public class ReportService {

    // 1. Cron 表達式 (秒 分 時 日 月 周)
    @Scheduled(cron = "0 0 2 * * ?") // 每天凌晨 2點
    public void dailyReport() { ... }

    // 2. 固定頻率 (毫秒)
    @Scheduled(fixedRate = 5000) // 每 5秒 (從上次開始算)
    public void heartbeat() { ... }

    // 3. 固定延遲 (毫秒)
    @Scheduled(fixedDelay = 5000) // 上次結束後 5秒
    public void cleanup() { ... }

    // 4. 初始延遲 + 固定頻率/延遲
    @Scheduled(initialDelay = 10000, fixedRate = 3600000) // 啟動 10秒後, 之後每小時
    public void syncData() { ... }

    // 5. 參數化配置 (從配置文件讀取)
    @Scheduled(cron = "${report.cron:0 0 2 * * ?}")
    public void configurableReport() { ... }
}

進階：動態定時任務 (運行時增刪改)

@Autowired private ThreadPoolTaskScheduler taskScheduler;
private ScheduledFuture dynamicTaskFuture;

public void startDynamicTask(Runnable task, long rateMs) {
    stopDynamicTask();
    dynamicTaskFuture = taskScheduler.scheduleAtFixedRate(task, rateMs);
}

public void stopDynamicTask() {
    if (dynamicTaskFuture != null) {
        dynamicTaskFuture.cancel(true);
        dynamicTaskFuture = null;
    }
}

public void rescheduleCronTask(String cron) {
    // 需手動解析 Cron -> Trigger
    CronTrigger trigger = new CronTrigger(cron);
    dynamicTaskFuture = taskScheduler.schedule(() -> {}, trigger);
}

生產級選型決策樹

是否 Spring 項目?
├── 是 → 需要集群/持久化/可視化管理/動態增刪?
│   ├── 是 → 接入 XXL-JOB / Elastic-Job / PowerJob / Quartz 集群模式
│   └── 否 → 直接用 @Scheduled + 自定義 TaskScheduler (最省事)
└── 否 (純 Java / 非 Spring)
    ├── 簡單測試/原型 → Timer (了解缺陷)
    ├── 基礎設施/庫/工具類 → ScheduledExecutorService (自定義線程池)
    └── 高可靠/分佈式需求 → 引入 Quartz 單機/集群 或 輕量調度庫 (e.g. db-scheduler)

常見坑點避雷

選型建議：Spring 項目首選 @Scheduled (配置線程池、錯誤處理、參數化)；非 Spring 基礎設施用 ScheduledExecutorService (自定義 ThreadFactory、拒絕策略、監控)；Timer 僅限學習/測試。需集群高可用、持久化、可視化、動態管理時，直接接入 XXL-JOB / Elastic-Job / PowerJob 成熟調度平台，勿重複造輪子。