diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java index 8a83e919f..973e6599f 100644 --- a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java +++ b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java @@ -1,5 +1,7 @@ package cn.hutool.core.thread; +import cn.hutool.core.util.RuntimeUtil; + import java.lang.Thread.UncaughtExceptionHandler; import java.util.concurrent.Callable; import java.util.concurrent.CompletionService; @@ -126,7 +128,7 @@ public class ThreadUtil { } // 最佳的线程数 = CPU可用核心数 / (1 - 阻塞系数) - int poolSize = (int) (Runtime.getRuntime().availableProcessors() / (1 - blockingCoefficient)); + int poolSize = (int) (RuntimeUtil.getProcessorCount() / (1 - blockingCoefficient)); return ExecutorBuilder.create().setCorePoolSize(poolSize).setMaxPoolSize(poolSize).setKeepAliveTime(0L).build(); } diff --git a/hutool-core/src/main/java/cn/hutool/core/util/RuntimeUtil.java b/hutool-core/src/main/java/cn/hutool/core/util/RuntimeUtil.java index ed927a440..8e88f4ccb 100755 --- a/hutool-core/src/main/java/cn/hutool/core/util/RuntimeUtil.java +++ b/hutool-core/src/main/java/cn/hutool/core/util/RuntimeUtil.java @@ -13,6 +13,7 @@ import java.nio.charset.Charset; import java.util.ArrayList; import java.util.List; import java.util.Stack; +import java.util.concurrent.ThreadPoolExecutor; /** * 系统运行时工具类,用于执行系统命令的工具 @@ -234,11 +235,21 @@ public class RuntimeUtil { /** * 获得JVM可用的处理器数量(一般为CPU核心数) * + *
+ * 这里做一个特殊的处理,在特殊的CPU上面,会有获取不到CPU数量的情况,所以这里做一个保护; + * 默认给一个7,真实的CPU基本都是偶数,方便区分。 + * 如果不做处理,会出现创建线程池时{@link ThreadPoolExecutor},抛出异常:{@link IllegalArgumentException} + *
+ * * @return 可用的处理器数量 * @since 5.3.0 */ public static int getProcessorCount() { - return Runtime.getRuntime().availableProcessors(); + int cpu = Runtime.getRuntime().availableProcessors(); + if (cpu <= 0) { + cpu = 7; + } + return cpu; } /** diff --git a/hutool-core/src/test/java/cn/hutool/core/util/RuntimeUtilTest.java b/hutool-core/src/test/java/cn/hutool/core/util/RuntimeUtilTest.java index c7a773156..41fe208ad 100644 --- a/hutool-core/src/test/java/cn/hutool/core/util/RuntimeUtilTest.java +++ b/hutool-core/src/test/java/cn/hutool/core/util/RuntimeUtilTest.java @@ -43,4 +43,11 @@ public class RuntimeUtilTest { int pid = RuntimeUtil.getPid(); Assert.assertTrue(pid > 0); } + + @Test + public void getProcessorCountTest(){ + int cpu = RuntimeUtil.getProcessorCount(); + Console.log("cpu个数:{}", cpu); + Assert.assertTrue(cpu > 0); + } } diff --git a/hutool-socket/src/test/java/cn/hutool/socket/aio/AioClientTest.java b/hutool-socket/src/test/java/cn/hutool/socket/aio/AioClientTest.java index 1a53476d8..a3fda7606 100755 --- a/hutool-socket/src/test/java/cn/hutool/socket/aio/AioClientTest.java +++ b/hutool-socket/src/test/java/cn/hutool/socket/aio/AioClientTest.java @@ -2,6 +2,7 @@ package cn.hutool.socket.aio; import cn.hutool.core.lang.Console; import cn.hutool.core.thread.ThreadFactoryBuilder; +import cn.hutool.core.util.RuntimeUtil; import cn.hutool.core.util.StrUtil; import java.io.IOException; @@ -12,7 +13,7 @@ import java.nio.channels.AsynchronousChannelGroup; public class AioClientTest { public static void main(String[] args) throws IOException { final AsynchronousChannelGroup GROUP = AsynchronousChannelGroup.withFixedThreadPool(// - Runtime.getRuntime().availableProcessors(), // 默认线程池大小 + RuntimeUtil.getProcessorCount(), // 默认线程池大小 ThreadFactoryBuilder.create().setNamePrefix("Huool-socket-").build()// );