summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-11-22 11:30:33 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-11-22 11:30:33 +0100
commit5b68313a7e3bd800a9bf7d3c1789b987108bb0c1 (patch)
treed1534185e1de693cf1a648a76fc457f20c5e0ed6 /container-search
parent83606d9c040e51e5e0b86b2546d42e09c0ac3818 (diff)
Use thread local random.
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java7
1 files changed, 3 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java
index eb937e00b17..7ecdb24c211 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java
@@ -18,7 +18,7 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
-import java.util.Random;
+import java.util.concurrent.ThreadLocalRandom;
/**
* RpcResourcePool constructs {@link FillInvoker} objects that communicate with content nodes over RPC. It also contains
@@ -32,7 +32,6 @@ public class RpcResourcePool extends AbstractComponent {
public final static CompoundName dispatchCompression = new CompoundName("dispatch.compression");
private final Compressor compressor = new Compressor(CompressionType.LZ4, 5, 0.95, 32);
- private final Random random = new Random();
/** Connections to the search nodes this talks to, indexed by node id ("partid") */
private final ImmutableMap<Integer, NodeConnectionPool> nodeConnectionPools;
@@ -90,7 +89,7 @@ public class RpcResourcePool extends AbstractComponent {
}
}
- private class NodeConnectionPool {
+ private static class NodeConnectionPool {
private final List<Client.NodeConnection> connections;
NodeConnectionPool(List<NodeConnection> connections) {
@@ -98,7 +97,7 @@ public class RpcResourcePool extends AbstractComponent {
}
Client.NodeConnection nextConnection() {
- int slot = random.nextInt(connections.size());
+ int slot = ThreadLocalRandom.current().nextInt(connections.size());
return connections.get(slot);
}