From c5c60984cb7f27d70602c50afb82c62fb7acd411 Mon Sep 17 00:00:00 2001
From: duandazhi <ab601026460@163.com>
Date: Fri, 2 Sep 2022 22:54:22 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DavailableProcessors=EF=BC=8C?=
 =?UTF-8?q?=E6=BD=9C=E5=9C=A8=E7=9A=84native=E6=96=B9=E6=B3=95=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96CPU=E4=B8=AA=E6=95=B0=E5=A4=B1=E8=B4=A5=E7=9A=84?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/cn/hutool/core/thread/ThreadUtil.java |  4 +++-
 .../main/java/cn/hutool/core/util/RuntimeUtil.java  | 13 ++++++++++++-
 .../java/cn/hutool/core/util/RuntimeUtilTest.java   |  7 +++++++
 .../java/cn/hutool/socket/aio/AioClientTest.java    |  3 ++-
 4 files changed, 24 insertions(+), 3 deletions(-)

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核心数）
 	 *
+	 * <p>
+	 *     这里做一个特殊的处理,在特殊的CPU上面，会有获取不到CPU数量的情况，所以这里做一个保护;
+	 *     默认给一个7，真实的CPU基本都是偶数，方便区分。
+	 *     如果不做处理，会出现创建线程池时{@link ThreadPoolExecutor}，抛出异常：{@link IllegalArgumentException}
+	 * </p>
+	 *
 	 * @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()//
 		);