REQ-2481: 添加删除日志表的job
This commit is contained in:
parent
be997df024
commit
1d60987414
@ -53,7 +53,7 @@ public class SendExecutor<T> implements Supplier<ExecResult> {
|
||||
long execStart = System.currentTimeMillis();
|
||||
while (!sendManager.isInterrupted() && !queue().isEmpty()) {
|
||||
if (!rateLimiter.tryAcquire(1000, TimeUnit.MILLISECONDS)) {
|
||||
//队列可能消息完了, 及早退出
|
||||
//队列可能被消费完了, 及早退出
|
||||
MiscUtils.sleepQuietly(100, TimeUnit.MILLISECONDS);
|
||||
continue;
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user