lsm/hutool
1
0
Fork 0
mirror of https://gitee.com/dromara/hutool.git synced 2025-05-25 01:19:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

!1231 add test

Browse Source 
Merge pull request !1231 from 温良恭/v6-dev
This commit is contained in:
Looly 2024-06-30 09:55:26 +00:00 committed by Gitee
commit 1572a95c3d
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -84,7 +84,7 @@ public class ThreadUtil {
* @param poolSize 同时执行的线程数大小 * @param poolSize 同时执行的线程数大小
* @return ExecutorService * @return ExecutorService
*/ */
public static ExecutorService newExecutor(final int poolSize) { public static ThreadPoolExecutor newExecutor(final int poolSize) {
return newExecutor(poolSize, poolSize); return newExecutor(poolSize, poolSize);
} }

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

@ -14,6 +14,7 @@ package org.dromara.hutool.core.thread;
import org.dromara.hutool.core.date.TimeUtil; import org.dromara.hutool.core.date.TimeUtil;
import org.dromara.hutool.core.exception.HutoolException; import org.dromara.hutool.core.exception.HutoolException;
import org.dromara.hutool.core.lang.Console;
import org.dromara.hutool.core.util.RandomUtil; import org.dromara.hutool.core.util.RandomUtil;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Disabled;
@ -21,14 +22,18 @@ import org.junit.jupiter.api.Test;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.concurrent.CyclicBarrier; import java.util.concurrent.*;
import java.util.concurrent.Phaser;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
public class ThreadUtilTest { public class ThreadUtilTest {
@Test
public void testNewExecutorByBlockingCoefficient(){
ThreadPoolExecutor executor = ThreadUtil.newExecutorByBlockingCoefficient(0.5f);
Console.log(executor.getCorePoolSize());
}
@Test @Test
public void executeTest() { public void executeTest() {
final boolean isValid = true; final boolean isValid = true;