summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-01-25 06:43:13 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-01-25 06:43:13 +0100
commit565a260840b8d284ac68f973adfc040237115c67 (patch)
tree346791c76cd981a806f884b150eae2618f45c7b7 /messagebus
parent6c1b116deeea86f0329dc1852e75157b054b555b (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.java2
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);