【記錄】【springboot】動態定時任務ScheduledFuture，可添加、修改、刪除

 

這里只演示添加和刪除任務的，因為修改就是刪除任務再添加而已。

方便演示，任務就是每3秒打印

 

1、沒有任務

 

 后台

 

 

2、添加一個任務

 

 

 

 

 

 

3、再添加一個任務

 

 

 

 

 

 

4、刪除一個任務

 

 

 

 

 

 

5、再添加一個任務

 

 

 

 

 

6、代碼

運行任務線程的代碼TaskRunnable.java

import com.xiaostudy.shiro_test1.utils.DateUtils;

public class TaskRunnable implements Runnable  {
    private String name;
    public TaskRunnable(String name) {
        this.name = name;
    }
    @Override
    public void run() {
        System.out.println(name + "---動態定時任務運行---" + DateUtils.getDateTime());
    }
}

 

TaskController.java

import com.xiaostudy.shiro_test1.task.TaskRunnable;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ScheduledFuture;
import java.util.stream.Collectors;

@Controller
@RequestMapping("/task")
public class TaskController {

    private Map<String, ScheduledFuture<?>> taskMap = new HashMap<>();

    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;

    @RequestMapping("addTask")
    @ResponseBody
    public boolean addTask(String name){
        String zhangsanCron = "*/3 * * * * ?";
        return add(name, zhangsanCron);
    }

    @RequestMapping("stopTask")
    @ResponseBody
    public boolean stopTask(String name){
        return stop(name);
    }

    @RequestMapping("listTask")
    @ResponseBody
    public String listTask(){
        return taskMap.keySet().stream().map(name -> name).collect(Collectors.joining(","));
    }

    private boolean add(String name, String cron) {
        if(null != taskMap.get(name)) {
            return false;
        }
        ScheduledFuture<?> schedule = threadPoolTaskScheduler.schedule(new TaskRunnable(name), new CronTrigger(cron));
        taskMap.put(name, schedule);
        return true;
    }

    private boolean stop(String name) {
        if(null == taskMap.get(name)) {
            return false;
        }
        ScheduledFuture<?> scheduledFuture = taskMap.get(name);
        scheduledFuture.cancel(true);
        taskMap.remove(name);
        return true;
    }
}

 

7、講解

開始定時任務就是ScheduledFuture<?> schedule = threadPoolTaskScheduler.schedule(new TaskRunnable(name), new CronTrigger(cron));

cron任務調度，比如*/3 * * * * ?表示每3秒執行任務

new TaskRunnable(name)就是實現Runnable的線程，任務處理在run()

ScheduledFuture<?>可以理解就是一個定時任務

 

任務保存在數據庫，當應用開啟后立刻查看所有任務，用Map<String, ScheduledFuture<?>>裝起來，key可以用id保證其唯一性

小白剛剛接觸，只有簡單的實現，沒有考慮數據量大等問題。僅做記錄