diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/thread/ThreadUtil.java b/hutool-core/src/main/java/org/dromara/hutool/core/thread/ThreadUtil.java index 00df2ab9d..005bf90df 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/thread/ThreadUtil.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/thread/ThreadUtil.java @@ -178,7 +178,7 @@ public class ThreadUtil { * @author luozongle * @since 5.8.0 */ - public static ExecutorService newFixedExecutor(final int nThreads, final int maximumQueueSize, final String threadNamePrefix, final boolean isBlocked) { + public static ThreadPoolExecutor newFixedExecutor(final int nThreads, final int maximumQueueSize, final String threadNamePrefix, final boolean isBlocked) { return newFixedExecutor(nThreads, maximumQueueSize, threadNamePrefix, (isBlocked ? RejectPolicy.BLOCK : RejectPolicy.ABORT).getValue()); } @@ -198,7 +198,7 @@ public class ThreadUtil { * @author luozongle * @since 5.8.0 */ - public static ExecutorService newFixedExecutor(final int nThreads, + public static ThreadPoolExecutor newFixedExecutor(final int nThreads, final int maximumQueueSize, final String threadNamePrefix, final RejectedExecutionHandler handler) { diff --git a/hutool-core/src/test/java/org/dromara/hutool/core/thread/ThreadUtilTest.java b/hutool-core/src/test/java/org/dromara/hutool/core/thread/ThreadUtilTest.java index 9cdba0241..bdfa941ec 100644 --- a/hutool-core/src/test/java/org/dromara/hutool/core/thread/ThreadUtilTest.java +++ b/hutool-core/src/test/java/org/dromara/hutool/core/thread/ThreadUtilTest.java @@ -28,6 +28,18 @@ import java.util.concurrent.atomic.AtomicInteger; public class ThreadUtilTest { + @Test + public void testNewFixedExecutor(){ + + ThreadPoolExecutor executor = ThreadUtil.newFixedExecutor(1, 2, "test-", true); + + for (int i = 0; i < 20; i++) { + executor.execute(()->{ + Console.log("执行任务1"); + }); + } + + } @Test public void testNewExecutorByBlockingCoefficient(){ ThreadPoolExecutor executor = ThreadUtil.newExecutorByBlockingCoefficient(0.5f);