From 48e1c5dc86b245c7392ed6e275180ea28c231e07 Mon Sep 17 00:00:00 2001 From: Redkale Date: Fri, 13 Jan 2023 19:17:49 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=BC=E6=A8=BA=E5=AF=B2ClientExecutor?= =?UTF-8?q?=E9=90=A8=E5=8B=AD=E5=9A=8E=E7=BB=8B=E5=AC=AB=E6=9A=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/boot/Application.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/redkale/boot/Application.java b/src/main/java/org/redkale/boot/Application.java index 8d21ea1e8..ef3a71dac 100644 --- a/src/main/java/org/redkale/boot/Application.java +++ b/src/main/java/org/redkale/boot/Application.java @@ -581,11 +581,10 @@ public final class Application { } ExecutorService workExecutor0 = null; - ExecutorService clientExecutor; if (executorConf == null) { executorConf = DefaultAnyValue.create(); } - final int workThreads = executorConf.getIntValue("threads", Math.max(2, Utility.cpus())); + final int workThreads = executorConf.getIntValue("threads", Utility.cpus() * 4); boolean workHash = executorConf.getBoolValue("hash", false); if (workThreads > 0) { if (workHash) { @@ -594,10 +593,10 @@ public final class Application { workExecutor0 = WorkThread.createExecutor(workThreads, "Redkale-WorkThread-%s"); } } - clientExecutor = workExecutor0; + ExecutorService clientExecutor = workExecutor0; if (clientExecutor == null) { //给所有client给一个默认的ExecutorService - final int clientThreads = Math.max(Math.max(2, Utility.cpus()), workThreads); + final int clientThreads = executorConf.getIntValue("clients", Utility.cpus()); clientExecutor = WorkThread.createExecutor(clientThreads, "Redkale-DefaultClient-WorkThread-%s"); }