Java并发工具类（二）CyclicBarrier

谁践踏了优雅 2022-03-20 10:06 200阅读 0赞

## Java并发工具类（二）CyclicBarrier ##

在J.U.C并发包中提供了一些工具类，可以供我们在日常的开发中，根据不同的情况去进行一些相关的并发控制，具体的类有：

> CountDownLatch  
> Semaphore  
> Exchanger  
> CyclicBarrier

### CyclicBarrier ###

#### 概念 ####

当有多个线程同时去访问的时候,会发生阻塞,直到最后一个线程达到屏障时,程序才会继续执行。

#### 实现 ####

public static void main(String[] args) { 
            int num = 5;
            CyclicBarrier barrier = new CyclicBarrier(num, new Leader());
            for (int i = 0; i < num; i++) { 
                new Thread(new Employees(barrier,i)).start();
            }
        }
    }
    
    class Leader implements Runnable { 
        @Override
        public void run() { 
            System.out.println("吃饭前我先说几句");
            try { 
                Thread.sleep(15000);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
        }
    }
    
    class Employees implements Runnable { 
    
        private CyclicBarrier barrier;
    
        private int num;
    
        public Employees(CyclicBarrier barrier, int num) { 
            this.barrier = barrier;
            this.num = num;
        }
    
        public void run() { 
            try { 
                System.out.println("员工 " + num + " 在等老板说完话准备吃");
                barrier.await();
            } catch (InterruptedException | BrokenBarrierException e) { 
                e.printStackTrace();
            }
            System.out.println("老板说了15分钟 " + "员工 " + num + " 准备开始吃了");
        }

#### 执行结果 ####

员工 0 在等老板说完话准备吃
    员工 2 在等老板说完话准备吃
    员工 1 在等老板说完话准备吃
    员工 3 在等老板说完话准备吃
    员工 4 在等老板说完话准备吃
    吃饭前我先说几句
    老板说了15分钟 员工 4 开始吃了
    老板说了15分钟 员工 3 开始吃了
    老板说了15分钟 员工 0 开始吃了
    老板说了15分钟 员工 1 开始吃了
    老板说了15分钟 员工 2 开始吃了

### CyclicBarrier和CountDownLatch的区别 ###

相同点：都是为了控制线程的执行顺序
    不同点：CountDownLatch的计数器只能使用一次,而CyclicBarrier的计数器可以使用reset()方法重置,所以CyclicBarrier能处理的业务场景相对CountDownLatch更多。

### 完整代码和相关依赖请见GitHub ###

[https://github.com/dwyanewede/project-learn/tree/master/src/main/java/com/learn/demo/concurrent][https_github.com_dwyanewede_project-learn_tree_master_src_main_java_com_learn_demo_concurrent]

### 相关文章推荐 ###

Java并发工具类（一）CountDownLatch [https://blog.csdn.net/shang\_xs/article/details/87075550][https_blog.csdn.net_shang_xs_article_details_87075550]  
Java并发工具类（三）Exchanger [https://blog.csdn.net/shang\_xs/article/details/87078321][https_blog.csdn.net_shang_xs_article_details_87078321]  
Java并发工具类（四）Semaphore [https://blog.csdn.net/shang\_xs/article/details/87090443][https_blog.csdn.net_shang_xs_article_details_87090443]

[https_github.com_dwyanewede_project-learn_tree_master_src_main_java_com_learn_demo_concurrent]: https://github.com/dwyanewede/project-learn/tree/master/src/main/java/com/learn/demo/concurrent
[https_blog.csdn.net_shang_xs_article_details_87075550]: https://blog.csdn.net/shang_xs/article/details/87075550
[https_blog.csdn.net_shang_xs_article_details_87078321]: https://blog.csdn.net/shang_xs/article/details/87078321
[https_blog.csdn.net_shang_xs_article_details_87090443]: https://blog.csdn.net/shang_xs/article/details/87090443