From 0cfb00e40be83656d7a64687905ae1971e50eed2 Mon Sep 17 00:00:00 2001 From: redkale Date: Tue, 28 Mar 2023 23:36:18 +0800 Subject: [PATCH] =?UTF-8?q?ClientConnection=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/net/client/ClientConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/redkale/net/client/ClientConnection.java b/src/main/java/org/redkale/net/client/ClientConnection.java index e24563734..801bb6972 100644 --- a/src/main/java/org/redkale/net/client/ClientConnection.java +++ b/src/main/java/org/redkale/net/client/ClientConnection.java @@ -90,7 +90,7 @@ public abstract class ClientConnection implements Co respFuture.setTimeout(client.timeoutScheduler.schedule(respFuture, rts, TimeUnit.SECONDS)); } respWaitingCounter.increment(); //放在writeChannelInWriteThread计数会延迟,导致不准确 - if (true || channel.inCurrWriteThread()) { //临时屏蔽 + if (channel.inCurrWriteThread()) { writeChannelInThread(request, respFuture); } else { channel.executeWrite(() -> writeChannelInThread(request, respFuture));