fix bug
This commit is contained in:
parent
16f8a16cb3
commit
7b839d0f83
@ -89,7 +89,7 @@ public class BeatReactor {
|
||||
if (beatInfo.isStop()) {
|
||||
return;
|
||||
}
|
||||
long nextTime = result > 0 ? System.currentTimeMillis() + result : System.currentTimeMillis() + beatInfo.getPeriod();
|
||||
long nextTime = result > 0 ? result : beatInfo.getPeriod();
|
||||
executorService.schedule(new BeatTask(beatInfo), nextTime, TimeUnit.MILLISECONDS);
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user