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

优化client

Browse Source
This commit is contained in:
redkale
2023-03-28 08:05:04 +08:00
parent 9ef977aee9
commit 94185cc23e
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/redkale/net/client/Client.java
View File

@@ -273,7 +273,8 @@ public abstract class Client<C extends ClientConnection<R, P>, R extends ClientR
protected CompletableFuture<C> connect() { protected CompletableFuture<C> connect() {
final int size = this.connArray.length; 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]; C cc = (C) this.connArray[connIndex];
if (cc != null && cc.isOpen()) { if (cc != null && cc.isOpen()) {
return CompletableFuture.completedFuture(cc); return CompletableFuture.completedFuture(cc);