From 94185cc23e662cec358ec80bc783d99f24125173 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Tue, 28 Mar 2023 08:05:04 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96client?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/client/Client.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/net/client/Client.java b/src/main/java/org/redkale/net/client/Client.java
index 087765032..33824ffdf 100644
--- a/src/main/java/org/redkale/net/client/Client.java
+++ b/src/main/java/org/redkale/net/client/Client.java
@@ -273,7 +273,8 @@ public abstract class Client<C extends ClientConnection<R, P>, R extends ClientR
 
     protected CompletableFuture<C> connect() {
         final int size = this.connArray.length;
-        final int connIndex = (int) Math.abs(connIndexSeq.getAndIncrement()) % size;
+        WorkThread workThread = WorkThread.currWorkThread();
+        final int connIndex = (workThread != null && workThread.threads() == size) ? workThread.index() : (int) Math.abs(connIndexSeq.getAndIncrement()) % size;
         C cc = (C) this.connArray[connIndex];
         if (cc != null && cc.isOpen()) {
             return CompletableFuture.completedFuture(cc);