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;