diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-01-25 06:43:13 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-01-25 06:43:13 +0100 |
commit | 565a260840b8d284ac68f973adfc040237115c67 (patch) | |
tree | 346791c76cd981a806f884b150eae2618f45c7b7 /messagebus | |
parent | 6c1b116deeea86f0329dc1852e75157b054b555b (diff) |
TransportThread must always do a handover. If not you might get a deadlock.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 2 |
1 files changed, 1 insertions, 1 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 fcc43afdd13..c457a703ecc 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 @@ -70,7 +70,7 @@ public class RPCNetwork implements Network, MethodHandler { private final ExecutorService executor = new ThreadPoolExecutor(getNumThreads(), getNumThreads(), 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), - ThreadFactoryFactory.getDaemonThreadFactory("mbus.net"), new ThreadPoolExecutor.CallerRunsPolicy()); + ThreadFactoryFactory.getDaemonThreadFactory("mbus.net")); private static int getNumThreads() { return Math.max(2, Runtime.getRuntime().availableProcessors()/2); |