diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-22 11:30:33 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-22 11:30:33 +0100 |
commit | 5b68313a7e3bd800a9bf7d3c1789b987108bb0c1 (patch) | |
tree | d1534185e1de693cf1a648a76fc457f20c5e0ed6 /container-search | |
parent | 83606d9c040e51e5e0b86b2546d42e09c0ac3818 (diff) |
Use thread local random.
Diffstat (limited to 'container-search')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java | 7 |
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); } |