REQ-2481: 添加删除日志表的job

This commit is contained in:
yanglin 2024-05-31 16:34:22 +08:00
parent 1d60987414
commit 768d0a265f

View File

@ -52,7 +52,7 @@ public class SendExecutor<T> implements Supplier<ExecResult> {
public final ExecResult get() {
long execStart = System.currentTimeMillis();
while (!sendManager.isInterrupted() && !queue().isEmpty()) {
if (!rateLimiter.tryAcquire(1000, TimeUnit.MILLISECONDS)) {
if (!rateLimiter.tryAcquire(200, TimeUnit.MILLISECONDS)) {
//队列可能被消费完了, 及早退出
MiscUtils.sleepQuietly(100, TimeUnit.MILLISECONDS);
continue;