最近遇到這樣的需求，要求是定時的執行任務，但是這些任務能夠根據控制及時的停止。

首先定時任務可以直接使用spring中的schedule註解方式實現。那麼如何控制已經啟動的任務及時停止呢？

下面說一下思路。首先利用spring的schedule註解方式進行定時任務的執行。然後，在每個定時任務中使用新建執行緒的方式進行任務的執行。在新建執行緒的run方法中通過檢測開關的狀態，如果開關開啟，則丟擲interruptException然後通過catch捕獲結束執行緒的執行即可。

下面是詳細的實現。

1、首先在spring boot中新增定時任務。

新增@EnableScheduling註解。

2、新增定時任務

package com.example.demo.task;


import com.example.demo.controller.TaskHelperController;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class TestTask {
    @Scheduled(cron = "0/5 * * * * ?")
    public void test() {
        Thread thread = new Thread(new Exetask());
        thread.start();
        System.out.println(thread.getName() + "===============begin" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()));
    }

    class Exetask implements Runnable {
        @Override
        public void run() {
            for (int i = 0; i < 100; i++) {
                try {
                    if (TaskHelperController.stopFlag) {
                        throw new InterruptedException();
                    }
                    Thread.sleep(3000);
                    System.out.println(Thread.currentThread().getName() + "   " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()));
                } catch (InterruptedException e) {
                    System.out.println(Thread.currentThread().getName() + "  stop!!!");
                    break;
                }
            }
        }
    }

}
 

3、對應的控制邏輯在另一個介面中

package com.example.demo.controller;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/taskHelper")
public class TaskHelperController {
    public static boolean stopFlag = false;

    @RequestMapping("/change")
    public String test(boolean flag) {
        TaskHelperController.stopFlag = flag;
        return "ok";
    }
}
 

4、這裡的開關標誌可以儲存在資料庫，快取等地方。