多线程(八、同步计数器-CyclicBarrier)

发布时间:2020-08-07 01:57:22 作者:shayang88
来源:网络 阅读:1156

CyclicBarrier-循环栅栏

线程到达栅栏时调用await方法被阻塞,只有线程数据达到栅栏设置的阈值时,栅栏放行,所有线程继续执行,此轮结束,栅栏进入下一轮。

案例:3个线程等待栅栏放行

Task

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

public class Task implements Runnable{

    private CyclicBarrier cyclicBarrier;

    public Task(CyclicBarrier cyclicBarrier) {
        this.cyclicBarrier = cyclicBarrier;
    }

    @Override
    public void run() {
        try {
            Thread.sleep(1000);
            System.out.println(Thread.currentThread().getName() + "准备就绪");
            cyclicBarrier.await();
        } catch (InterruptedException e) {
            System.out.println(Thread.currentThread().getName() + "中断了......");
        } catch (BrokenBarrierException e) {
            System.out.println(Thread.currentThread().getName() + "抛出损坏异常....");
        }
    }
}

启动文件

import java.util.concurrent.CyclicBarrier;

public class Main {

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

        System.out.println("主线程开始......");

        CyclicBarrier cb = new CyclicBarrier(3, new Runnable(){

            @Override
            public void run() {
                System.out.println("子线程全部就位,开始执行制定任务......");
            }
        });

        Thread t1 = new Thread(new Task(cb), "Thread-1");
        Thread t2 = new Thread(new Task(cb), "Thread-2");
        Thread t3 = new Thread(new Task(cb), "Thread-3");

        t1.start();
        t2.start();
        t3.start();

        Thread.sleep(2000);
        System.out.println("主线程执行完毕");
    }
}

结果:

多线程(八、同步计数器-CyclicBarrier)

CyclicBarrier的异常

CyclicBarrier如果不能满足阈值,超时或者等待的线程被中断了,则所有等待线程都会抛出损坏异常,然后进入下一轮。

多线程(八、同步计数器-CyclicBarrier)

案例:损坏异常,假设阈值为4,已经有3个线程等待,其中一个中断。

Task代码不变

启动文件修改

import java.util.concurrent.CyclicBarrier;

public class Main {

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

        System.out.println("主线程开始......");

        CyclicBarrier cb = new CyclicBarrier(4, new Runnable(){

            @Override
            public void run() {
                System.out.println("子线程全部就位,开始执行制定任务......");
            }
        });

        Thread t1 = new Thread(new Task(cb), "Thread-1");
        Thread t2 = new Thread(new Task(cb), "Thread-2");
        Thread t3 = new Thread(new Task(cb), "Thread-3");

        t1.start();
        t2.start();
        t3.start();
        Thread.sleep(1000);
        t1.interrupt();

        Thread.sleep(2000);
        System.out.println("主线程执行完毕");
    }
}

结果:

多线程(八、同步计数器-CyclicBarrier)

源码分析:

CyclicBarrier基于ReentrantLock和Condition实现锁机制。

多线程(八、同步计数器-CyclicBarrier)

成员变量

多线程(八、同步计数器-CyclicBarrier)

await方法:

多线程(八、同步计数器-CyclicBarrier)
多线程(八、同步计数器-CyclicBarrier)
多线程(八、同步计数器-CyclicBarrier)

breakBarrier损坏方法:

多线程(八、同步计数器-CyclicBarrier)

推荐阅读:
  1. 多线程之线程同步
  2. 多线程(七、同步计数器-CountDownLatch)

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

cyclicbarrier 循环栅栏 lic

上一篇:「SAP技术」为正常库存管理的物料做成本中心采购会是什么结果?

下一篇:华为设备的简单配置

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》