diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java index 2f24d6b4f3..d4f851fd13 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java @@ -64,7 +64,7 @@ public class CopycatTransportServer implements Server { this.messagingService = checkNotNull(messagingService); this.protocolMessageSubject = String.format("onos-copycat-server-%s", partitionId); this.newConnectionMessageSubject = String.format("onos-copycat-server-connection-%s", partitionId); - this.executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), + this.executorService = Executors.newScheduledThreadPool(Math.min(4, Runtime.getRuntime().availableProcessors()), new CatalystThreadFactory("copycat-server-p" + partitionId + "-%d")); }