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

优化ClientAddress

Browse Source
This commit is contained in:
Redkale
2023-01-05 22:31:05 +08:00
parent 310d6fe217
commit 442d806161
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/redkale/net/client/ClientAddress.java
View File

@@ -54,7 +54,8 @@ public class ClientAddress implements java.io.Serializable {
public CompletableFuture<AsyncConnection> createClient(final boolean tcp, final AsyncGroup group, int readTimeoutSeconds, int writeTimeoutSeconds) { public CompletableFuture<AsyncConnection> createClient(final boolean tcp, final AsyncGroup group, int readTimeoutSeconds, int writeTimeoutSeconds) {
SocketAddress addr = address; SocketAddress addr = address;
if (addr == null) { if (addr == null) {
if (this.addresses == null) { SocketAddress[] addrs = this.addresses;
if (addrs == null) {
synchronized (this) { synchronized (this) {
if (this.addresses == null) { if (this.addresses == null) {
int size = 0; int size = 0;
@@ -70,11 +71,11 @@ public class ClientAddress implements java.io.Serializable {
newAddrs[++index] = w.getAddress(); newAddrs[++index] = w.getAddress();
} }
} }
addrs = newAddrs;
this.addresses = newAddrs; this.addresses = newAddrs;
} }
} }
} }
SocketAddress[] addrs = addresses;
addr = addrs[ThreadLocalRandom.current().nextInt(addrs.length)]; addr = addrs[ThreadLocalRandom.current().nextInt(addrs.length)];
} }
return group.createClient(tcp, addr, readTimeoutSeconds, writeTimeoutSeconds); return group.createClient(tcp, addr, readTimeoutSeconds, writeTimeoutSeconds);