java多线程开发之通过对战游戏学习CyclicBarrier

private String player;
private CyclicBarrier barrier;

public StartGame(String player, CyclicBarrier barrier) {
 this.player = player;
 this.barrier = barrier;
}

public void run() {
 try {
  System.out.println(this.getPlayer()+" 开始匹配玩家...");
  findOtherPlayer();
  barrier.await();

  System.out.println(this.getPlayer()+" 进行选择角色...");
  choiceRole();
  System.out.println(this.getPlayer()+" 角色选择完毕等待其他玩家...");
  barrier.await();

  System.out.println(this.getPlayer()+" 开始游戏,进行游戏加载...");
  loading();
  System.out.println(this.getPlayer()+" 游戏加载完毕等待其他玩家加载完成...");
  barrier.await();


  start();
 } catch (Exception e){
  e.printStackTrace();
 }
}

Thread.sleep()

public CyclicBarrier(int parties) {}
public CyclicBarrier(int parties, Runnable barrierAction) {}

public static void main(String[] args) throws IOException {
 CyclicBarrier barrier = new CyclicBarrier(5);

 Thread player1 = new Thread(new StartGame("1",barrier));
 Thread player2 = new Thread(new StartGame("2",barrier));
 Thread player3 = new Thread(new StartGame("3",barrier));
 Thread player4 = new Thread(new StartGame("4",barrier));
 Thread player5 = new Thread(new StartGame("5",barrier));

 player1.start();
 player2.start();
 player3.start();
 player4.start();
 player5.start();

 System.in.read();
}

CyclicBarrier barrier = new CyclicBarrier(5, () -> {
 try {
  System.out.println("阶段完成，等待2秒...");
  Thread.sleep(2000);
  System.out.println("进入下个阶段...");
 } catch (InterruptedException e) {
  e.printStackTrace();
 }

});

public int await(){}
public int await(long timeout, TimeUnit unit){}

java.util.concurrent.TimeoutException
java.util.concurrent.BrokenBarrierException

private int dowait(boolean timed, long nanos){
 //加锁、try catch代码
 final Generation g = generation;
 //判断栅栏的状态
 if (g.broken)
  throw new BrokenBarrierException();
 //...省略

 int index = --count;
 //(index == 0) 时的代码，省略

 for (;;) {
  try {
   if (!timed)
    trip.await();
   else if (nanos > 0L)
    nanos = trip.awaitNanos(nanos);
  } catch (InterruptedException ie) {}

  //判断栅栏的状态
  if (g.broken)
   throw new BrokenBarrierException();

  if (g != generation)
   return index;
  //判断是否是定时的，且已经超时了
  if (timed && nanos <= 0L) {
   //打破栅栏的状态
   breakBarrier();
   throw new TimeoutException();
  }
 }
 //解锁
}

private void breakBarrier() {
 generation.broken = true;
 count = parties;
 trip.signalAll();
}