ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-04-19 03:01:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

1.修改创建线程池返回类

Browse Source 
2.add Test
This commit is contained in:
wenlianggong 2024-07-01 20:38:53 +08:00
parent b587caca0d
commit 5474735197
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hutool-core/src/main/java/org/dromara/hutool/core/thread/ThreadUtil.java
View File

@ -178,7 +178,7 @@ public class ThreadUtil {
* @author luozongle * @author luozongle
* @since 5.8.0 * @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, return newFixedExecutor(nThreads, maximumQueueSize, threadNamePrefix,
(isBlocked ? RejectPolicy.BLOCK : RejectPolicy.ABORT).getValue()); (isBlocked ? RejectPolicy.BLOCK : RejectPolicy.ABORT).getValue());
} }
@ -198,7 +198,7 @@ public class ThreadUtil {
* @author luozongle * @author luozongle
* @since 5.8.0 * @since 5.8.0
*/ */
public static ExecutorService newFixedExecutor(final int nThreads, public static ThreadPoolExecutor newFixedExecutor(final int nThreads,
final int maximumQueueSize, final int maximumQueueSize,
final String threadNamePrefix, final String threadNamePrefix,
final RejectedExecutionHandler handler) { final RejectedExecutionHandler handler) {

12
hutool-core/src/test/java/org/dromara/hutool/core/thread/ThreadUtilTest.java
View File

@ -28,6 +28,18 @@ import java.util.concurrent.atomic.AtomicInteger;
public class ThreadUtilTest { 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 @Test
public void testNewExecutorByBlockingCoefficient(){ public void testNewExecutorByBlockingCoefficient(){
ThreadPoolExecutor executor = ThreadUtil.newExecutorByBlockingCoefficient(0.5f); ThreadPoolExecutor executor = ThreadUtil.newExecutorByBlockingCoefficient(0.5f);