From e0d3f2e4c549e289a250704d628ceb7a8d30b4af Mon Sep 17 00:00:00 2001
From: duandazhi <ab601026460@163.com>
Date: Wed, 3 Aug 2022 23:24:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=EF=BC=9AnewPhaser?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/hutool/core/thread/ThreadUtil.java     | 29 ++++++++++++++++++-
 1 file changed, 28 insertions(+), 1 deletion(-)

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 7a0d44e6f..a4e651d9e 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
@@ -287,7 +287,7 @@ public class ThreadUtil {
 	 *             e.printStackTrace();
 	 *         }
 	 *         System.out.printf("【%s】同学，已经离开了教室%n", Thread.currentThread().getName());
-	 *         latch.countDown(); // 减1（每离开一个同学，减去1）
+	 *         latch.countDown(); // 减1（每离开一个同学，减去1）,必须执行，可以放到 try...finally中
 	 *     },"同学 - " + x).start();
 	 * }
 	 * latch.await(); // 等待计数为0后再解除阻塞；（等待所有同学离开）
@@ -304,10 +304,37 @@ public class ThreadUtil {
 
 	/**
 	 * 新建一个Phaser，一个同步辅助类，jdk1.7提供，可以完全替代CountDownLatch；
+	 * @since 6.0.1
+	 * @author dazer
 	 *
 	 * Pharser: 移相器、相位器，可重用同步屏障；
 	 * 功能可以替换：{@link CyclicBarrier}（固定线程）循环栅栏、{@link CountDownLatch}（固定计数）倒数计数、加上分层功能
 	 *
+	 * 示例1：等6个同学都离开教室，班长才能锁门。
+	 * <pre>{@code
+	 * Phaser phaser = new Phaser(6); // 总共任务是6
+	 *  for (int x = 0; x < 6; x++) {
+	 *   //具体生产任务，可以用线程池替换
+	 *     new Thread(()->{
+	 *         try {
+	 *           //每个同学在角色待上5秒钟
+	 *             TimeUnit.SECONDS.sleep(5);
+	 *         } catch (InterruptedException e) {
+	 *             e.printStackTrace();
+	 *         }
+	 *         System.out.printf("【%s】同学，已经离开了教室%n", Thread.currentThread().getN
+	 *         phaser.arrive(); // 减1 等价于countDown()方法（每离开一个同学，减去1）,必须执行，可以放到 try...finally中
+	 *     },"同学 - " + x).start();
+	 * }
+	 * phaser.awaitAdvance(phaser.getPhase()); // 等价于latch.await()方法 等待计数为0后再解除阻塞；（等待所有同学离开）
+	 * System.out.println("【主线程】所有同学都离开了教室，开始锁教室大门了。");
+	 * }
+	 * </pre>
+	 *
+	 * 示例2：7个同学，集齐7个龙珠，7个同学一起召唤神龙；
+	 * 只需要：phaser.arrive(); --> phaser.arriveAndAwaitAdvance() //等待其他的线程就位
+	 * 该示例，也可以用：{@link CyclicBarrier} 进行实现
+	 *
 	 * @param taskCount 任务数量
 	 * @return Phaser
 	 */