【记录】【springboot】动态定时任务ScheduledFuture，可添加、修改、删除

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());
    }
}

 1 import com.xiaostudy.shiro_test1.task.TaskRunnable;
 2 import org.springframework.beans.factory.annotation.Autowired;
 3 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 4 import org.springframework.scheduling.support.CronTrigger;
 5 import org.springframework.stereotype.Controller;
 6 import org.springframework.web.bind.annotation.RequestMapping;
 7 import org.springframework.web.bind.annotation.ResponseBody;
 8 
 9 import java.util.HashMap;
10 import java.util.Map;
11 import java.util.concurrent.ScheduledFuture;
12 import java.util.stream.Collectors;
13 
14 @Controller
15 @RequestMapping("/task")
16 public class TaskController {
17 
18     private Map<String, ScheduledFuture<?>> taskMap = new HashMap<>();
19 
20     @Autowired
21     private ThreadPoolTaskScheduler threadPoolTaskScheduler;
22 
23     @RequestMapping("addTask")
24     @ResponseBody
25     public boolean addTask(String name){
26         String zhangsanCron = "*/3 * * * * ?";
27         return add(name, zhangsanCron);
28     }
29 
30     @RequestMapping("stopTask")
31     @ResponseBody
32     public boolean stopTask(String name){
33         return stop(name);
34     }
35 
36     @RequestMapping("listTask")
37     @ResponseBody
38     public String listTask(){
39         return taskMap.keySet().stream().map(name -> name).collect(Collectors.joining(","));
40     }
41 
42     private boolean add(String name, String cron) {
43         if(null != taskMap.get(name)) {
44             return false;
45         }
46         ScheduledFuture<?> schedule = threadPoolTaskScheduler.schedule(new TaskRunnable(name), new CronTrigger(cron));
47         taskMap.put(name, schedule);
48         return true;
49     }
50 
51     private boolean stop(String name) {
52         if(null == taskMap.get(name)) {
53             return false;
54         }
55         ScheduledFuture<?> scheduledFuture = taskMap.get(name);
56         scheduledFuture.cancel(true);
57         taskMap.remove(name);
58         return true;
59     }
60 }