@@ -35,3 +35,61 @@ cron4j的增强版本,cron4j的计划任务管理是每个执行计划由一
35
35
36
36
```
37
37
38
+ ```
39
+ package example;
40
+
41
+ import java.util.ArrayList;
42
+ import java.util.List;
43
+
44
+ import it.sauronsoftware.cron4j.Scheduler;
45
+ import it.sauronsoftware.cron4j.TimerThreadPoolMananger;
46
+ /**
47
+ * Cron4jEnhance使用说明
48
+ * @author chm
49
+ *
50
+ */
51
+ public class TestCron4jEnhance {
52
+
53
+ public static void main(String[] args) throws InterruptedException {
54
+
55
+ List<String> schList = new ArrayList<String>();
56
+ schList.add("*/1 * * * 1-7");
57
+ schList.add("*/1 * * * 1-7");
58
+ // schList.add("1 9-20/5 * * 1-5");
59
+ // schList.add("30 08-18/4 * * 1-7");
60
+ TimerThreadPoolMananger ttpm = TimerThreadPoolMananger.getInstance();
61
+ //设置计划任务的守护线程数
62
+ ttpm.setTimerHandScheduleCount(2);
63
+ for (String scheduler : schList) {
64
+ Scheduler sch = new Scheduler();
65
+ String uuid = sch.schedule(scheduler, new Runnable() {
66
+ public void run() {
67
+ System.out.println(System.currentTimeMillis() + "Scheduler exec!");
68
+ }
69
+ });
70
+
71
+ System.out.println("Scheduler: " + uuid);
72
+ //添加么个计划管理到任务管理池中
73
+ ttpm.addScheduler(sch);
74
+ }
75
+ ttpm.start();
76
+
77
+ Thread.sleep(2 * 60 * 1000);
78
+ System.out.println("Test ------------");
79
+ Scheduler sch = new Scheduler();
80
+ String uuid = sch.schedule("*/2 * * * 1-7", new Runnable() {
81
+ public void run() {
82
+ System.out.println(System.currentTimeMillis() + " new Scheduler exec!");
83
+ }
84
+ });
85
+
86
+ ttpm.addScheduler(sch);
87
+
88
+ Thread.sleep(4 * 60 * 1000);
89
+
90
+ sch.reschedule(uuid, "*/1 * * * 1-7");
91
+
92
+ }
93
+ }
94
+
95
+ ```
0 commit comments