From 0910a42e5eb9505a91b6e02801c9b8bd492800fc Mon Sep 17 00:00:00 2001 From: wenlianggong Date: Fri, 28 Jun 2024 21:46:12 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9=20ThreadUtil.newExecutor?= =?UTF-8?q?=20=E5=88=9B=E5=BB=BA=E7=BA=BF=E7=A8=8B=E6=B1=A0=E8=BF=94?= =?UTF-8?q?=E5=9B=9E=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/org/dromara/hutool/core/thread/ThreadUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 356573018..0189d5dca 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 @@ -84,7 +84,7 @@ public class ThreadUtil { * @param poolSize 同时执行的线程数大小 * @return ExecutorService */ - public static ExecutorService newExecutor(final int poolSize) { + public static ThreadPoolExecutor newExecutor(final int poolSize) { return newExecutor(poolSize, poolSize); } From b587caca0d7a485561c84ae10d16c46992505952 Mon Sep 17 00:00:00 2001 From: wenlianggong Date: Sat, 29 Jun 2024 20:24:56 +0800 Subject: [PATCH 2/2] add Test --- .../dromara/hutool/core/thread/ThreadUtilTest.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) 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 ebaefe6fd..9cdba0241 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 @@ -14,6 +14,7 @@ package org.dromara.hutool.core.thread; import org.dromara.hutool.core.date.TimeUtil; import org.dromara.hutool.core.exception.HutoolException; +import org.dromara.hutool.core.lang.Console; import org.dromara.hutool.core.util.RandomUtil; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Disabled; @@ -21,14 +22,18 @@ import org.junit.jupiter.api.Test; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; -import java.util.concurrent.CyclicBarrier; -import java.util.concurrent.Phaser; -import java.util.concurrent.ThreadLocalRandom; -import java.util.concurrent.TimeUnit; +import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; public class ThreadUtilTest { + + @Test + public void testNewExecutorByBlockingCoefficient(){ + ThreadPoolExecutor executor = ThreadUtil.newExecutorByBlockingCoefficient(0.5f); + Console.log(executor.getCorePoolSize()); + } + @Test public void executeTest() { final boolean isValid = true;