java CyclicBarrier的介绍和使用

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * Created by lv xiao long on 2017/7/16.
 */
public class Work implements Runnable {

    private CyclicBarrier barrier;
    private String msg;

    public Work(String msg, CyclicBarrier  barrier){
        this.msg=msg;
        this.barrier=barrier;
    }
    public void run() {
        while (true) {
            System.out.print(msg);
            try {
                barrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
            break;
        }
    }
}

import java.util.concurrent.CyclicBarrier;

/**
 * by lv xiao long
 *
 */
public class App 
{
    public static void main( String[] args )
    {
        //这里设置公共屏障点为3，两个子线程都到达屏障点后，主线程在放行，进入下账目录入，所以这里设置屏障点数为3
        CyclicBarrier cyclicBarrier=new CyclicBarrier(3);
        Work work=new Work("工作人员A录入完成\n",cyclicBarrier);
        Thread thread=new Thread(work);
        thread.start();
        work=new Work("工作人员B录入完成\n",cyclicBarrier);
        thread=new Thread(work);
        thread.start();
        try {
            cyclicBarrier.await();
            System.out.println( "可以开始进行下一账目录入！\n" );
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 /**
     * Creates a new <tt>CyclicBarrier</tt> that will trip when the
     * given number of parties (threads) are waiting upon it, and which
     * will execute the given barrier action when the barrier is tripped,
     * performed by the last thread entering the barrier.
     *
     * @param parties the number of threads that must invoke {@link #await}
     *        before the barrier is tripped
     * @param barrierAction the command to execute when the barrier is
     *        tripped, or {@code null} if there is no action
     * @throws IllegalArgumentException if {@code parties} is less than 1
     */
    public CyclicBarrier(int parties, Runnable barrierAction) {
        if (parties <= 0) throw new IllegalArgumentException();
        this.parties = parties;
        this.count = parties;
        this.barrierCommand = barrierAction;
    }