lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ClientConnection优化

Browse Source
This commit is contained in:
redkale
2023-03-28 23:36:18 +08:00
parent 3cf560f220
commit 0cfb00e40b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/redkale/net/client/ClientConnection.java
View File

@@ -90,7 +90,7 @@ public abstract class ClientConnection<R extends ClientRequest, P> implements Co
respFuture.setTimeout(client.timeoutScheduler.schedule(respFuture, rts, TimeUnit.SECONDS)); respFuture.setTimeout(client.timeoutScheduler.schedule(respFuture, rts, TimeUnit.SECONDS));
} }
respWaitingCounter.increment(); //放在writeChannelInWriteThread计数会延迟，导致不准确 respWaitingCounter.increment(); //放在writeChannelInWriteThread计数会延迟，导致不准确
if (true || channel.inCurrWriteThread()) { //临时屏蔽 if (channel.inCurrWriteThread()) {
writeChannelInThread(request, respFuture); writeChannelInThread(request, respFuture);
} else { } else {
channel.executeWrite(() -> writeChannelInThread(request, respFuture)); channel.executeWrite(() -> writeChannelInThread(request, respFuture));