diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-04-22 11:06:08 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-04-22 11:06:08 +0200 |
commit | 6a61110fef80bebfdd7fe7725005a6560974b22d (patch) | |
tree | 16524d0b347527c9159f7cc31702d5ece8c9ca7c /messagebus | |
parent | ec48ae56010aad00477263c28943054662f9412c (diff) | |
parent | dc86f6980fcba598c7c5c331bc62a6f80546dbf3 (diff) |
Merge pull request #9151 from vespa-engine/balder/less-mbus-threads
Cut number of network worker threads in half.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java index ad28fe81196..4ba8f6f0312 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java @@ -43,7 +43,6 @@ import java.util.concurrent.SynchronousQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; -import java.util.logging.Logger; import java.util.stream.Collectors; /** @@ -53,7 +52,6 @@ import java.util.stream.Collectors; */ public class RPCNetwork implements Network, MethodHandler { - private static final Logger log = Logger.getLogger(RPCNetwork.class.getName()); private final AtomicBoolean destroyed = new AtomicBoolean(false); private final Identity identity; private final Supervisor orb; @@ -67,10 +65,12 @@ public class RPCNetwork implements Network, MethodHandler { private final SlobrokConfigSubscriber slobroksConfig; private final LinkedHashMap<String, Route> lruRouteMap = new LinkedHashMap<>(10000, 0.5f, true); private final ExecutorService executor = - new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), Runtime.getRuntime().availableProcessors(), - 0L, TimeUnit.SECONDS, + new ThreadPoolExecutor(getNumThreads(), getNumThreads(), 0L, TimeUnit.SECONDS, new SynchronousQueue<>(false), ThreadFactoryFactory.getDaemonThreadFactory("mbus.net"), new ThreadPoolExecutor.CallerRunsPolicy()); + private static int getNumThreads() { + return Math.max(2, Runtime.getRuntime().availableProcessors()/2); + } /** * Create an RPCNetwork. The servicePrefix is combined with session names to create service names. If the service |