diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java
index c41fe4617..de79b82eb 100644
--- a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java
+++ b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java
@@ -274,8 +274,7 @@ public class ThreadUtil {
}
/**
- * 新建一个CountDownLatch,一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。
- *
+ * 新建一个CountDownLatch,一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。
* 示例:等6个同学都离开教室,班长才能锁门。
*
{@code * CountDownLatch latch = new CountDownLatch(6); // 总共任务是6 @@ -297,7 +296,7 @@ public class ThreadUtil { * System.out.println("【主线程】所有同学都离开了教室,开始锁教室大门了。"); * } *- * + *
* 该示例,也可以用:{@link Phaser} 移相器 进行实现
*
* @param taskCount 任务数量
@@ -308,8 +307,7 @@ public class ThreadUtil {
}
/**
- * 新建一个CycleBarrier 循环栅栏,一个同步辅助类
- *
+ * 新建一个CycleBarrier 循环栅栏,一个同步辅助类
* 示例:7个同学,集齐7个龙珠,7个同学一起召唤神龙;前后集齐了2次
*
{@code * AtomicInteger times = new AtomicInteger(); @@ -338,8 +336,9 @@ public class ThreadUtil { * }, "线程 - " + x).start(); * } * }- * + *
* 该示例,也可以用:{@link Phaser} 移相器 进行实现 + * * @param taskCount 任务数量 * @return 循环栅栏 */ @@ -349,12 +348,13 @@ public class ThreadUtil { /** * 新建一个Phaser,一个同步辅助类,jdk1.7提供,可以完全替代CountDownLatch; - * @since 6.0.1 + * + * @param taskCount 任务数量 + * @return Phaser * @author dazer - * + *
* Pharser: 移相器、相位器,可重用同步屏障;
- * 功能可以替换:{@link CyclicBarrier}(固定线程)循环栅栏、{@link CountDownLatch}(固定计数)倒数计数、加上分层功能
- *
+ * 功能可以替换:{@link CyclicBarrier}(固定线程)循环栅栏、{@link CountDownLatch}(固定计数)倒数计数、加上分层功能
* 示例1:等6个同学都离开教室,班长才能锁门。
*
{@code * Phaser phaser = new Phaser(6); // 总共任务是6 @@ -376,13 +376,11 @@ public class ThreadUtil { * System.out.println("【主线程】所有同学都离开了教室,开始锁教室大门了。"); * } *- * + *
* 示例2:7个同学,集齐7个龙珠,7个同学一起召唤神龙; * 只需要:phaser.arrive(); --> phaser.arriveAndAwaitAdvance() //等待其他的线程就位 * 该示例,也可以用:{@link CyclicBarrier} 进行实现 - * - * @param taskCount 任务数量 - * @return Phaser + * @since 6.0.1 */ public static Phaser newPhaser(final int taskCount) { return new Phaser(taskCount); @@ -741,6 +739,7 @@ public class ThreadUtil { * @return {@link ConcurrencyTester} * @since 4.5.8 */ + @SuppressWarnings("resource") public static ConcurrencyTester concurrencyTest(final int threadSize, final Runnable runnable) { return (new ConcurrencyTester(threadSize)).test(runnable); } @@ -761,8 +760,8 @@ public class ThreadUtil { * 注意:此方法的延迟和周期的单位均为毫秒。 * *