Skip to content

Commit

Permalink
[ISSUE #7261] Slave high CPU usage when enableScheduleAsyncDeliver=tr…
Browse files Browse the repository at this point in the history
…ue (#7262)

* [ISSUE #6390] Add break to the exception of WHEEL_TIMER_NOT_ENABLE.

* fix broker start fail if mapped file size is 0

* log

* only delete the last empty file

* change dataReadAheadEnable default to true

* fix endless loop when master change to slave.
  • Loading branch information
yuz10 committed Aug 29, 2023
1 parent 3e10010 commit fa54915
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -566,7 +566,8 @@ public void run() {
pendingQueue.remove();
break;
case RUNNING:
break;
scheduleNextTask();
return;
case EXCEPTION:
if (!isStarted()) {
log.warn("HandlePutResultTask shutdown, info={}", putResultProcess.toString());
Expand All @@ -586,6 +587,10 @@ public void run() {
}
}

scheduleNextTask();
}

private void scheduleNextTask() {
if (isStarted()) {
ScheduleMessageService.this.handleExecutorService
.schedule(new HandlePutResultTask(this.delayLevel), DELAY_FOR_A_SLEEP, TimeUnit.MILLISECONDS);
Expand Down

0 comments on commit fa54915

Please sign in to comment.