From 547473519703625007b5e267bb2f6b1f801b1c0f Mon Sep 17 00:00:00 2001 From: wenlianggong Date: Mon, 1 Jul 2024 20:38:53 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E5=88=9B=E5=BB=BA=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=B1=A0=E8=BF=94=E5=9B=9E=E7=B1=BB=202.add=20Test?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/dromara/hutool/core/thread/ThreadUtil.java | 4 ++-- .../dromara/hutool/core/thread/ThreadUtilTest.java | 12 ++++++++++++ 2 files changed, 14 insertions(+), 2 deletions(-) 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 0189d5dca..6b5e15cf5 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);