src/org/redkale/boot/Application.java

@@ -361,6 +361,7 @@ public final class Application {
     }
 
     public void init() throws Exception {
+        System.setProperty("sun.nio.ch.internalThreadPoolSize", "" + Runtime.getRuntime().availableProcessors() * 4);
         System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "" + Runtime.getRuntime().availableProcessors() * 4);
         System.setProperty("net.transport.poolmaxconns", "100");
         System.setProperty("net.transport.pinginterval", "30");

src/org/redkale/net/Server.java

@@ -128,7 +128,7 @@ public abstract class Server<K extends Serializable, C extends Context, R extend
         this.maxbody = parseLenth(config.getValue("maxbody"), 64 * 1024);
         int bufCapacity = parseLenth(config.getValue("bufferCapacity"), 32 * 1024);
         this.bufferCapacity = bufCapacity < 8 * 1024 ? 8 * 1024 : bufCapacity;
-        this.threads = config.getIntValue("threads", Runtime.getRuntime().availableProcessors() * 8);
+        this.threads = config.getIntValue("threads", Runtime.getRuntime().availableProcessors() * 32);
         this.bufferPoolSize = config.getIntValue("bufferPoolSize", this.threads * 4);
         this.responsePoolSize = config.getIntValue("responsePoolSize", this.threads * 2);
         this.name = config.getValue("name", "Server-" + protocol + "-" + this.address.getPort());

src/org/redkale/net/TcpAioProtocolServer.java

@@ -32,7 +32,7 @@ public class TcpAioProtocolServer extends ProtocolServer {
 
     @Override
     public void open(AnyValue config) throws IOException {
-        group = AsynchronousChannelGroup.withCachedThreadPool(context.executor, 1);
+        group = AsynchronousChannelGroup.withThreadPool(context.executor);
         this.serverChannel = AsynchronousServerSocketChannel.open(group);
 
         final Set<SocketOption<?>> options = this.serverChannel.supportedOptions();