From 1d48ead94cdd2bdaa740bebea25882e8af0cac20 Mon Sep 17 00:00:00 2001
From: wenlianggong <wenlianggong>
Date: Thu, 27 Jun 2024 20:30:01 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=20ThreadUtil.newExecutor=20?=
 =?UTF-8?q?=E5=88=9B=E5=BB=BA=E7=BA=BF=E7=A8=8B=E6=B1=A0=E8=BF=94=E5=9B=9E?=
 =?UTF-8?q?=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/cn/hutool/core/thread/ThreadUtil.java   |  2 +-
 .../java/cn/hutool/core/thread/ThreadUtilTest.java    | 11 +++++++++++
 2 files changed, 12 insertions(+), 1 deletion(-)

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 2baafdf2a..75f3281cb 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
@@ -35,7 +35,7 @@ public class ThreadUtil {
 	 * @param corePoolSize 同时执行的线程数大小
 	 * @return ExecutorService
 	 */
-	public static ExecutorService newExecutor(int corePoolSize) {
+	public static ThreadPoolExecutor newExecutor(int corePoolSize) {
 		ExecutorBuilder builder = ExecutorBuilder.create();
 		if (corePoolSize > 0) {
 			builder.setCorePoolSize(corePoolSize);
diff --git a/hutool-core/src/test/java/cn/hutool/core/thread/ThreadUtilTest.java b/hutool-core/src/test/java/cn/hutool/core/thread/ThreadUtilTest.java
index e793693ac..395a9ed17 100644
--- a/hutool-core/src/test/java/cn/hutool/core/thread/ThreadUtilTest.java
+++ b/hutool-core/src/test/java/cn/hutool/core/thread/ThreadUtilTest.java
@@ -4,8 +4,19 @@ import cn.hutool.core.util.RandomUtil;
 import org.junit.Assert;
 import org.junit.Test;
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.ThreadPoolExecutor;
+
 public class ThreadUtilTest {
 
+
+	@Test
+	public void newExecutorTest(){
+		ThreadPoolExecutor executor = ThreadUtil.newExecutor(5);
+		// 查询线程池 线程数
+		Assert.assertEquals(5, executor.getCorePoolSize());
+	}
+
 	@Test
 	public void executeTest() {
 		final boolean isValid = true;