diff --git a/sms-aggregation-comm/src/main/java/kim/wind/sms/comm/delayedTime/DelayedTime.java b/sms-aggregation-comm/src/main/java/kim/wind/sms/comm/delayedTime/DelayedTime.java
index 78fd8461..bd1c7851 100644
--- a/sms-aggregation-comm/src/main/java/kim/wind/sms/comm/delayedTime/DelayedTime.java
+++ b/sms-aggregation-comm/src/main/java/kim/wind/sms/comm/delayedTime/DelayedTime.java
@@ -4,43 +4,20 @@ import java.util.*;
/**
*
类名: DelayedTime
- *
说明: 定时器队列
- *
+ *
说明: 定时器
* @author :Wind
* 2023/3/25 21:22
**/
public class DelayedTime {
- private final List queue = Collections.synchronizedList(new ArrayList<>());
+ private final Timer timer = new Timer(true);
- public DelayedTime() {
- Timer timer = new Timer(true);
- Thread t = new Thread(() -> {
- while (true) try {
- if (queue.size() == 0){
- continue;
- }
- Task take = queue.remove(0);
- timer.schedule(take.getRunnable(), take.getTime());
- } catch (Exception e) {
- e.printStackTrace();
- }
- });
- t.start();
- }
/**
* 延迟队列添加新任务
*/
public void schedule(TimerTask task, long delay) {
- try {
- Task tasks = new Task();
- tasks.setTime(delay);
- tasks.setRunnable(task);
- queue.add(tasks);
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
+ timer.schedule(task,delay);
}
}