wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
yanglin 2024-05-31 16:33:28 +08:00
parent 1658040fd1
commit be997df024
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
im-center-server/src/main/java/cn/axzo/im/send/SendExecutor.java
View File

@ -51,12 +51,10 @@ public class SendExecutor<T> implements Supplier<ExecResult> {
@Override
public final ExecResult get() {
long execStart = System.currentTimeMillis();
int acquireSeconds = 1;
// 当tps设置过小(比如: 0.01)而消息已经被其它通道发送完时
// 当前executor就算没事做也会导致强制等待若干时间, 使用tryAcquire避免这种情况发生
while (!sendManager.isInterrupted() && !queue().isEmpty()) {
if (!rateLimiter.tryAcquire(acquireSeconds, TimeUnit.SECONDS)) {
MiscUtils.sleepQuietly(acquireSeconds, TimeUnit.SECONDS);
if (!rateLimiter.tryAcquire(1000, TimeUnit.MILLISECONDS)) {
//队列可能消息完了, 及早退出
MiscUtils.sleepQuietly(100, TimeUnit.MILLISECONDS);
continue;
}
T record = sendHandler.getSendRecord(this);