Commit 9c15a34a by huangfusuper

调整时间

parent 7f2c988c
...@@ -24,11 +24,16 @@ public class WorkRoulette { ...@@ -24,11 +24,16 @@ public class WorkRoulette {
* maxPendingTimeouts:最大等待处理超时 * maxPendingTimeouts:最大等待处理超时
*/ */
private static final HashedWheelTimer HASHED_WHEEL_TIMER = new HashedWheelTimer(r -> new Thread(r, "HASHED_WHEEL_TIMER" + r.hashCode()), 1, TimeUnit.SECONDS, 8, true, 0); private static final HashedWheelTimer HASHED_WHEEL_TIMER = new HashedWheelTimer(r -> new Thread(r, "HASHED_WHEEL_TIMER" + r.hashCode()), 1, TimeUnit.SECONDS, 8, true, 0);
public static final int INT = 500;
public static void addJob(TimerTask timerTask,long triggerNextTime) { public static void addJob(TimerTask timerTask,long triggerNextTime) {
log.info("-----任务{}毫秒后执行-------",triggerNextTime-System.currentTimeMillis()); log.debug("-----任务{}毫秒后执行-------",triggerNextTime-System.currentTimeMillis());
HASHED_WHEEL_TIMER.newTimeout(timerTask, TimeUnit.MILLISECONDS.toNanos(triggerNextTime-System.currentTimeMillis()), TimeUnit.NANOSECONDS); long time = triggerNextTime-System.currentTimeMillis();
if(time < INT){
time = INT;
}
HASHED_WHEEL_TIMER.newTimeout(timerTask, TimeUnit.MILLISECONDS.toNanos(time), TimeUnit.NANOSECONDS);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment