import java.util.concurrent.Phaser;
 
/***
 *  下面說說Phaser的高級用法，在Phaser內(nèi)有2個重要狀態(tài)，分別是phase和party。
 *  phase就是階段，初值為0，當(dāng)所有的線程執(zhí)行完本輪任務(wù)，同時開始下一輪任務(wù)時，
 *  意味著當(dāng)前階段已結(jié)束，進入到下一階段，phase的值自動加1。party就是線程，
 *  party=4就意味著Phaser對象當(dāng)前管理著4個線程。Phaser還有一個重要的方法經(jīng)常需要被重載，
 *  那就是boolean onAdvance(int phase, int registeredParties)方法。此方法有2個作用：
 *  1、當(dāng)每一個階段執(zhí)行完畢，此方法會被自動調(diào)用，因此，重載此方法寫入的代碼會在每個階段執(zhí)行完畢時執(zhí)行，
 *  相當(dāng)于CyclicBarrier的barrierAction。
 *  2、當(dāng)此方法返回true時，意味著Phaser被終止，因此可以巧妙的設(shè)置此方法的返回值來終止所有線程。
 * @author liujun
 */
public class MyPhaser extends Phaser {
 
	@Override
	protected boolean onAdvance(int phase, int registeredParties) {	//在每個階段執(zhí)行完成后回調(diào)的方法
		
		switch (phase) {
		case 0:
			return studentArrived();
		case 1:
			return finishFirstExercise();
		case 2:
			return finishSecondExercise();
		case 3:
			return finishExam();
		default:
			return true;
		}
		
	}
	
	private boolean studentArrived(){
		System.out.println("學(xué)生準(zhǔn)備好了,學(xué)生人數(shù)："+getRegisteredParties());
		return false;
	}
	
	private boolean finishFirstExercise(){
		System.out.println("第一題所有學(xué)生做完");
		return false;
	}
	
	private boolean finishSecondExercise(){
		System.out.println("第二題所有學(xué)生做完");
		return false;
	}
	
	private boolean finishExam(){
		System.out.println("第三題所有學(xué)生做完，結(jié)束考試");
		return true;
	}
	
}

import java.util.concurrent.Phaser;
import java.util.concurrent.TimeUnit;
 
public class StudentTask implements Runnable {
 
	private Phaser phaser;
	
	public StudentTask(Phaser phaser) {
		this.phaser = phaser;
	}
 
	@Override
	public void run() {
		System.out.println(Thread.currentThread().getName()+"到達(dá)考試");
		phaser.arriveAndAwaitAdvance();
		
		System.out.println(Thread.currentThread().getName()+"做第1題時間...");
		doExercise1();
		System.out.println(Thread.currentThread().getName()+"做第1題完成...");
		phaser.arriveAndAwaitAdvance();
		
		System.out.println(Thread.currentThread().getName()+"做第2題時間...");
		doExercise2();
		System.out.println(Thread.currentThread().getName()+"做第2題完成...");
		phaser.arriveAndAwaitAdvance();
		
		System.out.println(Thread.currentThread().getName()+"做第3題時間...");
		doExercise3();
		System.out.println(Thread.currentThread().getName()+"做第3題完成...");
		phaser.arriveAndAwaitAdvance();
	}
 
	private void doExercise1() {
		long duration = (long)(Math.random()*10);
		try {
			TimeUnit.SECONDS.sleep(duration);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	
	private void doExercise2() {
		long duration = (long)(Math.random()*10);
		try {
			TimeUnit.SECONDS.sleep(duration);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	
	private void doExercise3() {
		long duration = (long)(Math.random()*10);
		try {
			TimeUnit.SECONDS.sleep(duration);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	
}

/**
 * 題目：5個學(xué)生參加考試，一共有三道題，要求所有學(xué)生到齊才能開始考試
 * ，全部做完第一題，才能繼續(xù)做第二題，后面類似。
 * 
 * Phaser有phase和party兩個重要狀態(tài)，
 * phase表示階段，party表示每個階段的線程個數(shù)，
 * 只有每個線程都執(zhí)行了phaser.arriveAndAwaitAdvance();
 * 才會進入下一個階段，否則阻塞等待。
 * 例如題目中5個學(xué)生(線程)都條用phaser.arriveAndAwaitAdvance();就進入下一題
 * @author liujun
 */
public class Main {
 
	public static void main(String[] args) {
		MyPhaser phaser = new MyPhaser();
		StudentTask[] studentTask = new StudentTask[5];
		for (int i = 0; i < studentTask.length; i++) {
			studentTask[i] = new StudentTask(phaser);
			phaser.register();	//注冊一次表示phaser維護的線程個數(shù)
		}
		
		Thread[] threads = new Thread[studentTask.length];
		for (int i = 0; i < studentTask.length; i++) {
			threads[i] = new Thread(studentTask[i], "Student "+i);
			threads[i].start();
		}
		
		//等待所有線程執(zhí)行結(jié)束
		for (int i = 0; i < studentTask.length; i++) {
			try {
				threads[i].join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		
		System.out.println("Phaser has finished:"+phaser.isTerminated());
		
	}
	
}