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);
     }
 }