Java并发编程二-CyclicBarrier【黑马java培训】

更新时间:2022年12月01日 15时05分51秒来源:黑马程序员论坛

一、什么是关卡？

　　关卡类似于闭锁，它们都能阻塞一组线程，直到某些事件发生。

　　关卡和闭锁关键的不同在于，所有线程必须同时到达关卡点，才能继续处理。闭锁等待的是事件，关卡等待的是其他线程。

二、CyclicBarrier

　　CyclicBarrier 的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活。

　　当线程到达关卡点时，调用await方法，await会被阻塞，直到所有的线程都到达关卡点。如果所有的线程都到达了关卡点，关卡就会被突破，这样所有的线程都被释放，关卡会重置以备下一次使用。如果对await的方法调用超时，或者阻塞中的线程被中断，那么关卡就被认为是失败的，所有对await未完成的调用都通过BrokenBarrierException终止。

　　CyclicBarrier默认的构造方法是CyclicBarrier(int parties)，其参数表示屏障拦截的线程数量，每个线程调用await方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。

　　实例代码如下：

[Java] 纯文本查看 复制代码

public class CyclicBarrierTest
{
    public static void main(String[] args) throws InterruptedException, BrokenBarrierException
    {
        CyclicBarrier cyclicBarrier=new CyclicBarrier(4);
        for(int i=0;i<3;i++)
        {
            new Writer(cyclicBarrier).start();
        }
        cyclicBarrier.await();
        System.out.println("所有数据均写完！");
    }
    static class Writer extends Thread
    {
        CyclicBarrier cyclicBarrier;
        public Writer(CyclicBarrier cyclicBarrier)
        {
            this.cyclicBarrier=cyclicBarrier;
        }
        @Override
        public void run()
        {
            try
            {
                Thread.sleep(1000);
                System.out.println("线程"+Thread.currentThread().getName()+"写入数据完毕，等待其他线程写入完毕");
                cyclicBarrier.await();
            } catch (Exception e)
            {
                // TODO 自动生成的 catch 块
                e.printStackTrace();
            }
            
        }
    }
}

　　输出

　　CyclicBarrier还提供一个更高级的构造函数CyclicBarrier(int parties, Runnable barrierAction)，用于在线程到达屏障时，优先执行barrierAction，方便处理更复杂的业务场景。代码如下：

[Java] 纯文本查看 复制代码

public class CyclicBarrierTest2
{
     final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
     public static void main(String[] args)
    {
         CyclicBarrier end = new CyclicBarrier(2,new MainTask());// 两个工人的协作

         Worker worker1 = new Worker("zhang san", 5000, end);
         Worker worker2 = new Worker("li si", 8000,end);
         
         worker1.start();
         worker2.start();
    }
     static class MainTask implements Runnable
     {   
            public void run() 
            {   
                    System.out.println("执行最后的任务");   
            }   
    }  
     static class Worker extends Thread
        {
            String workerName;
            int workTime;
           
            CyclicBarrier end;
            public Worker(String workerName, int workTime, CyclicBarrier end)
            {
                this.workerName = workerName;
                this.workTime = workTime;
                this.end = end;
            }
            public void run()
            {
                try
                {
                    System.out.println("Worker " + workerName + " do work begin at "+ sdf.format(new Date()));
                    Thread.sleep(workTime);
                    System.out.println("Worker " + workerName + " do work complete at " + sdf.format(new Date()));
                } 
                catch (InterruptedException e)
                {
                    // TODO 自动生成的 catch 块
                    e.printStackTrace();
                }
                finally
                {
                    try
                    {
                        end.await();
                    } catch (InterruptedException | BrokenBarrierException e)
                    {
                        // TODO 自动生成的 catch 块
                        e.printStackTrace();
                    }
                }
            }
        }
}

　　输出：

三、CyclicBarrier和CountDownLatch的区别

CountDownLatch的计数器只能使用一次，而CyclicBarrier的计数器可以使用reset()方法重置，因此CyclicBarrier能够处理更为复杂的业务场景，比如如果计算发送错误，可以重置计数器，并让线程重新执行一次。
CountDownLatch是减计数方式，计数==0时释放所有等待的线程；CyclicBarrier是加计数方式，计数达到构造方法中参数指定的值时释放所有等待的线程。
CountDownLatch当计数到0时，计数无法被重置；CyclicBarrier计数达到指定值时，计数置为0重新开始。
CountDownLatch每次调用countDown()方法计数减一，调用await()方法只进行阻塞，对计数没任何影响；CyclicBarrier只有一个await()方法，调用await()方法计数加1，若加1后的值不等于构造方法的值，则线程阻塞。
CountDownLatch：一个或者是一部分线程，等待另外一部线程都完成了，再继续执行。
CyclicBarrier：所有线程互相等待完成。

推荐了解热门学科

java培训	Python人工智能	Web前端培训	PHP培训
区块链培训	影视制作培训	C++培训	产品经理培训
UI设计培训	新媒体培训	产品经理培训	Linux运维
大数据培训	智能机器人软件开发

传智播客是一家致力于培养高素质软件开发人才的科技公司，“黑马程序员”是传智播客旗下高端IT教育品牌。自“黑马程序员”成立以来，教学研发团队一直致力于打造精品课程资源，不断在产、学、研3个层面创新自己的执教理念与教学方针，并集中“黑马程序员”的优势力量，针对性地出版了计算机系列教材50多册，制作教学视频数+套，发表各类技术文章数百篇。

传智播客从未停止思考

传智播客副总裁毕向东在2019IT培训行业变革大会提到，“传智播客意识到企业的用人需求已经从初级程序员升级到中高级程序员，具备多领域、多行业项目经验的人才成为企业用人的首选。”

中级程序员和初级程序员的差别在哪里?
项目经验。毕向东表示，“中级程序员和初级程序员最大的差别在于中级程序员比初级程序员多了三四年的工作经验，从而多出了更多的项目经验。“为此，传智播客研究院引进曾在知名IT企业如阿里、IBM就职的高级技术专家，集中研发面向中高级程序员的课程，用以满足企业用人需求，尽快补全IT行业所需的人才缺口。

何为中高级程序员课程?

传智播客进行了定义。中高级程序员课程，是在当前主流的初级程序员课程的基础上，增加多领域多行业的含金量项目，从技术的广度和深度上进行拓展。“我们希望用5年的时间，打造上百个高含金量的项目，覆盖主流的32个行业。”传智播客课程研发总监于洋表示。

黑马程序员热门视频教程【点击播放】

Python入门教程完整版（懂中文就能学会）	零起点打开Java世界的大门
C++\| 匠心之作从0到1入门学编程	PHP\|零基础入门开发者编程核心技术
Web前端入门教程_Web前端html+css+JavaScript	软件测试入门到精通

全国中心

Java并发编程二-CyclicBarrier【黑马java培训】

最新资讯

相关阅读