爱编程,爱生活

java concurrent 之 CyclicBarrier

2018-06-16  本文已影响20人  熬夜的猫头鹰

java concurrent 之 CyclicBarrier

CyclicBarrier 的字面意思是可循环使用(Cyclic)的屏障(Barrier)。它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续干活。CyclicBarrier默认的构造方法是CyclicBarrier(int parties),其参数表示屏障拦截的线程数量,每个线程调用await方法告诉CyclicBarrier我已经到达了屏障,然后当前线程被阻塞。

直接上代码


package com.viashare.cyclicbarrier;

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

/**
 * Created by Jeffy on 16/01/11.
 */
public class CyclicBarrierMain {

    private final static int NUM = 10;

    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(NUM ,new BarrierAction());
        for (int i = 0; i < NUM; i++) {
            new Thread(new CyclicBarrierRunnable(cyclicBarrier,i)).start();

        }
        cyclicBarrier.reset();
    }


    static class CyclicBarrierRunnable implements Runnable {
        CyclicBarrier barrier1 = null;

        private int no = 0;

        public CyclicBarrierRunnable(CyclicBarrier barrier1, int no) {
            this.barrier1 = barrier1;
            this.no = no;
        }

        @Override
        public void run() {
            try {
                if(no == 2){
//                    int a = 8/0;
//                    barrier1.reset();
                }
                System.out.println(Thread.currentThread().getName() + " waiting at barrier 1");
                Thread.sleep(3000);
                System.err.println("waiting thread count is "+ barrier1.getNumberWaiting());


                this.barrier1.await();
                System.out.println(Thread.currentThread().getName() + " done!");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }catch (Exception e){
                e.printStackTrace();

            }

        }
    }

    static class BarrierAction implements  Runnable{

        @Override
        public void run() {
            System.err.println("the last thread has arrived");
        }
    }
}


代码说明:

栅栏使用的场景样例

CyclicBarrier可以用于多线程计算数据,最后合并计算结果的应用场景。比如我们用一个Excel保存了用户所有银行流水,每个Sheet保存一个帐户近一年的每笔银行流水,现在需要统计用户的日均银行流水,先用多线程处理每个sheet里的银行流水,都执行完之后,得到每个sheet的日均银行流水,最后,再用barrierAction用这些线程的计算结果,计算出整个Excel的日均银行流水

不过也不尽然,使用线程池返回一个Future对象了来处理也是一个很好的多线程实现方案。

CyclicBarrier和CountDownLatch的区别

上一篇下一篇

猜你喜欢

热点阅读