From f8df4dfc10dee120b9daa2d4cd0ca60de1037530 Mon Sep 17 00:00:00 2001 From: jiaoshuaiyi Date: Fri, 22 Sep 2023 20:27:57 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E6=95=88=E7=9A=84?= =?UTF-8?q?=E5=88=A4=E6=96=AD=E4=BB=A3=E7=A0=81;?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hippo4j/common/toolkit/ThreadPoolExecutorUtil.java | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/infra/common/src/main/java/cn/hippo4j/common/toolkit/ThreadPoolExecutorUtil.java b/infra/common/src/main/java/cn/hippo4j/common/toolkit/ThreadPoolExecutorUtil.java index ae600924..b6fc97eb 100644 --- a/infra/common/src/main/java/cn/hippo4j/common/toolkit/ThreadPoolExecutorUtil.java +++ b/infra/common/src/main/java/cn/hippo4j/common/toolkit/ThreadPoolExecutorUtil.java @@ -37,13 +37,7 @@ public final class ThreadPoolExecutorUtil { */ public static void safeSetPoolSize(ThreadPoolExecutor executor, int newCorePoolSize, int newMaximumPoolSize) { Assert.isTrue(newCorePoolSize <= newMaximumPoolSize, "newCorePoolSize must be smaller than newMaximumPoolSize"); - int originalMaximumPoolSize = executor.getMaximumPoolSize(); - if (newCorePoolSize > originalMaximumPoolSize) { - executor.setMaximumPoolSize(newMaximumPoolSize); - executor.setCorePoolSize(newCorePoolSize); - } else { - executor.setCorePoolSize(newCorePoolSize); - executor.setMaximumPoolSize(newMaximumPoolSize); - } + executor.setMaximumPoolSize(newMaximumPoolSize); + executor.setCorePoolSize(newCorePoolSize); } }