zoukankan      html  css  js  c++  java
  • CyclicBarrier分析与实例

    一,介绍


        ​CyclicBarrier是一个保持多个线程共享同一个状态的工具类。

    也就是说在多线程环境下,能够通过设定某一个状态来达到线程之间的同步。这个类有两个有參构造方法。各自是CyclicBarrier(int n)和CyclicBarrier(int n, Runnable r)。第一个构造方法的意思是指给这个类设置等待点到多少时才运行在run方法中调用await方法之后的操作;第二个构造器的Runnable能够看作一个等待点的狼烟,狼烟是什么,是一种信号。也就是说,在等待线程达到n这个数量之后,会開始运行run方法中调用await方法之后的代码,而在调用这些代码前,会先放狼烟,然后再运行那些代码。

        这个类在多线程统计数据时还是非常实用的。可是要注意,假设你的线程数量总是达不到设置的n的数量,那么这时,操作将被堵塞,即await方法后面的代码总是不能运行。

    二,样例

    package test;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.Random;
    import java.util.concurrent.BrokenBarrierException;
    import java.util.concurrent.CyclicBarrier;
    
    public class CyclicBarrrierTest {
        static int count = 0;
        
        static List<Integer> data= Collections.synchronizedList(new ArrayList<Integer>());
        public static void main(String[] args) {
            //设置2个等待线程,存在两个等待线程时,计算集合中的何,然后再清除集合中的数据
            CyclicBarrier cb = new CyclicBarrier(2, new Runnable() {
                public void run() {
                    int sum = 0;
                    for(int i = 0; i < data.size(); i++) {
                        sum += data.get(i);
                    }
                    System.out.println("current sum is " + sum);
                    data.clear();
                }
            });
            int n = 10;
            for(int i =0 ; i< n; i++) {
                new Thread(new CBThread(2, cb,data)).start();  //开启n个线程
            }
        }
    
    }
    
    class CBThread implements Runnable{
        private int n;
        private CyclicBarrier cb;
        private List<Integer> data;
        public CBThread(int n,CyclicBarrier cb,List<Integer> data) {
            this.n = n;
            this.cb = cb;
            this.data = data;
        }
        
        public void run() {
            Random random = new Random();
    //        while(!done()) {  
                int n = random.nextInt(10);
                data.add(n);
                System.out.println(Thread.currentThread().getName() + " ======" + n + ",  " + cb.getNumberWaiting());
                try {
                    cb.await();  //await方法后面的代码总是在cb.getNumberWait等于n的时候才运行
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
                System.out.println("走起......" + CyclicBarrrierTest.count);
    //        }
        }
        
        private boolean done() {
            return false;
        }
    }
    
    


  • 相关阅读:
    struts传值方式ModelDriven的使用
    sql查询count 单独字段不同值
    图片-文件上传下载
    HTML 字符实体 &lt; &gt: &amp;等
    Validation failed for object='employee'. Error count: 1问题解决
    MySQL查询本周、上周、本月、上个月份数据的sql脚本
    React前端框架路由跳转,前端回车事件、禁止空格、提交方式等方法
    环境变量误删path找回方法与mysql基础命令
    树结构的控制
    数据库查询方法
  • 原文地址:https://www.cnblogs.com/slgkaifa/p/7351348.html
Copyright © 2011-2022 走看看