diff --git a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java index 3db6f26dc..be323d3d3 100644 --- a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java +++ b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java @@ -69,7 +69,7 @@ public class NetworkClient extends NetworkEventSource implements IConnection, Au /** Indicates whether the connection is established and first message is sent. */ public boolean isReady() { return ready; } - private final EventLoopGroup workerGroup = new NioEventLoopGroup(new DefaultThreadFactory("DH-Network - Client Thread")); + private final EventLoopGroup workerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("DH-Network - Client Thread")); private final Bootstrap clientBootstrap = new Bootstrap() .group(this.workerGroup) .channel(NioSocketChannel.class) diff --git a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java index a9a77fd55..d62a26876 100644 --- a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java +++ b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java @@ -47,7 +47,7 @@ public class NetworkServer extends NetworkEventSource implements AutoCloseable private final int port; private final EventLoopGroup bossGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("DH-Network - Server Boss Thread")); - private final EventLoopGroup workerGroup = new NioEventLoopGroup(new DefaultThreadFactory("DH-Network - Server Worker Thread")); + private final EventLoopGroup workerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("DH-Network - Server Worker Thread")); private final AtomicBoolean isClosed = new AtomicBoolean(); private final ConcurrentMap connections = new MapMaker().weakKeys().weakValues().makeMap();