• Java基础—循环栅栏CyclicBarrier


    循环栅栏CyclicBarrier

    CyclicBarrier特别适用于并行迭代计算,每个线程负责一部分计算,然后在栅栏处等待其他线程完成,所有线程到齐后,交换数据和计算结果,再进行下一次迭代。

    CountDownLatch类似,它也有一个数字,但表示的是参与的线程个数,这个数字通过构造方法进行传递:

    public CyclicBarrier(int parties)

    它还有一个构造方法,接受一个Runnable参数,如下所示:

    public CyclicBarrier(int parties, Runnable barrierAction)

    这个参数表示栅栏动作,当所有线程到达栅栏后,在所有线程执行下一步动作前,运行参数中的动作,这个动作由最后一个到达栅栏的线程执行。

    CyclicBarrier的主要方法就是await:
    public int await() throws InterruptedException, BrokenBarrierException
    public int await(long timeout, TimeUnit unit) throws InterruptedException,
        BrokenBarrierException, TimeoutException

    await在等待其他线程到达栅栏,调用await后,表示自己已经到达,如果自己是最后一个到达的,就执行可选的命令,执行后,唤醒所有等待的线程,然后重置内部的同步计数,以循环使用。

    await可以被中断,可以限定最长等待时间,中断或超时后会抛出异常。需要说明的是异常BrokenBarr

  • 相关阅读:
    Docker Harbor概述及构建
    LeetCode 69.x的平方根
    【紫光同创国产FPGA教程】——【PGL22G第七章】串口收发实验例程
    [蓝桥杯 2022 省 B] 统计子矩阵
    OBS键盘插件自定义diy
    java集合框架
    Minio入门系列 MinIO Client使用详解
    集群调度-01
    自动化测试08
    qt操作sqlite数据库
  • 原文地址:https://blog.csdn.net/m0_72882572/article/details/127557132