18 CyclicBarrier CountDownLacth

import java.io.IOException;  

import java.util.Random;  

import java.util.concurrent.BrokenBarrierException;  

import java.util.concurrent.CyclicBarrier;  

import java.util.concurrent.ExecutorService;  

import java.util.concurrent.Executors;

public class UseCyclicBarrier {

static class Runner implements Runnable {  

    private CyclicBarrier barrier;  

    private String name;  

    public Runner(CyclicBarrier barrier, String name) {  

        this.barrier = barrier;  

        this.name = name;  

    }  

    @Override  

    public void run() {  

        try {  

            Thread.sleep(1000 * (new Random()).nextInt(5));  

            System.out.println(name + "OK.");  

            barrier.await();  

        } catch (InterruptedException e) {  

            e.printStackTrace();  

        } catch (BrokenBarrierException e) {  

            e.printStackTrace();  

        }  

        System.out.println(name + " Go!!");  

    }  

}

    public static void main(String[] args) throws IOException, InterruptedException {  

        /**

         * 当达到3个await后，一起执行等待后面的代码

         */

    CyclicBarrier barrier = new CyclicBarrier(3);  // 3

        ExecutorService executor = Executors.newFixedThreadPool(3);  

        executor.submit(new Thread(new Runner(barrier, "zhangsan")));  

        executor.submit(new Thread(new Runner(barrier, "lisi")));  

        executor.submit(new Thread(new Runner(barrier, "wangwu")));  

        executor.shutdown();  

    }  

}  

代码结果：

lisiOK.

wangwuOK.

zhangsanOK.

zhangsan Go!!

wangwu Go!!

lisi Go!!