From b31186c8d38d3519faab7965de38eedb3efc8bb2 Mon Sep 17 00:00:00 2001
From: jaysunxiao <jaysunxiao.gmail.com>
Date: Sun, 10 Oct 2021 14:13:45 +0800
Subject: [PATCH] =?UTF-8?q?perf[scheduler]:=20=E5=88=A0=E9=99=A4=E4=B8=8D?=
 =?UTF-8?q?=E5=BF=85=E8=A6=81=E7=9A=84=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../zfoo/scheduler/manager/SchedulerBus.java  | 19 -------------------
 .../java/com/zfoo/util/security/IdUtils.java  |  2 +-
 2 files changed, 1 insertion(+), 20 deletions(-)

diff --git a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
index 320c54f8..416c93e2 100644
--- a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
+++ b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
@@ -13,7 +13,6 @@
 
 package com.zfoo.scheduler.manager;
 
-import com.zfoo.protocol.collection.CollectionUtils;
 import com.zfoo.scheduler.SchedulerContext;
 import com.zfoo.scheduler.model.vo.SchedulerDefinition;
 import com.zfoo.scheduler.timeWheelUtils.Timer;
@@ -22,8 +21,6 @@ import com.zfoo.scheduler.util.TimeUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.List;
-import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
@@ -98,22 +95,6 @@ public abstract class SchedulerBus {
         }, delay, unit);
     }
 
-    /**
-     * cron表达式执行的任务
-     */
-    public static void scheduleCron(Runnable runnable, String cron) {
-        if (SchedulerContext.isStop()) {
-            return;
-        }
-
-        SchedulerDefinition scheduler = SchedulerDefinition.valueOf(cron, runnable);
-        var timerTask = new TimerTask(scheduler.getTriggerTimestamp(), () -> {
-            scheduler.getScheduler().invoke();
-            refreshTask(scheduler);
-        });
-        timer.addTask(timerTask);
-    }
-
     public static void refreshTask(SchedulerDefinition schedulerDefinition) {
         var timestamp = TimeUtils.currentTimeMillis();
         var nextTriggerTimestamp = TimeUtils.getNextTimestampByCronExpression(schedulerDefinition.getCronExpression(), timestamp);
diff --git a/util/src/main/java/com/zfoo/util/security/IdUtils.java b/util/src/main/java/com/zfoo/util/security/IdUtils.java
index 4e81c899..d5898348 100644
--- a/util/src/main/java/com/zfoo/util/security/IdUtils.java
+++ b/util/src/main/java/com/zfoo/util/security/IdUtils.java
@@ -25,7 +25,7 @@ public abstract class IdUtils {
     private static final AtomicInteger ATOMIC_INTEGER = new AtomicInteger(0);
 
     /**
-     * 本地int的id，如果达到最大值则重新从最小值重新计算
+     * 获取本地int的唯一id，如果达到最大值则重新从最小值重新计算，线程安全
      */
     public static int getLocalIntId() {
         return ATOMIC_INTEGER.incrementAndGet();