江苏龙网

  1. 主页 > 生活百科 > >

常用的并发工具类( 二 )

并发工具类

CyclicBarrier与 CountDownLatch 功能一样，不过它可以重复循环，而 CountDownLatch 只能执行一次 。
【常用的并发工具类】实现原理：

  • 基于 ReentrantLock 和 Condition
//同步操作锁private final ReentrantLock lock = new ReentrantLock();//线程拦截器private final Condition trip = lock.newCondition();//每次拦截的线程数private final int parties;//换代前执行的任务private final Runnable barrierCommand;//表示栅栏的当前代private Generation generation = new Generation();//计数器private int count;//静态内部类Generationprivate static class Generation {  boolean broken = false;
  • 上面贴出了 CyclicBarrier 所有的成员变量，可以看到 CyclicBarrier 内部使通过条件 trip 来对线程进行阻塞 。
  • 并且其内部维护了两个 int 型变量 parites 和 count，parties 表示每次拦截的线程数，该值在构造时进行赋值 。count 是内部计数器，他的初始值和 parties 相同，以后随着每次 await 方法的调用而减一，直到减为零将唤醒主线程 。
  • CyclicBarrier 有一个静态内部类 Generation，该类的对象代表栅栏的当前代，就像玩游戏时代表的本局游戏，利用它可以实现循环等待 。
  • barrierCommand 表示换代前执行的任务，当 count 减为零时表示本局游戏结束，需要转到下一局 。在转到下一局游戏之前，利用它可以实现循环等待 。
package test;import java.util.concurrent.CyclicBarrier;public class Test2 {    static class TaskThread extends Thread{        CyclicBarrier barrier;        public TaskThread(CyclicBarrier barrier){            this.barrier = barrier;        }        @Override        public void run(){            try{                Thread.sleep(100);                System.out.println(getName() + "到达栅栏 A");                barrier.await();              // 等待所有线程都执行到这，才执行主线程                System.out.println(getName() + "冲破栅栏 A");   // 主线程完成后继续执行                Thread.sleep(2000);                System.out.println(getName() + "到达栅栏 B");                barrier.await();                System.out.println(getName() + "冲破栅栏 B");            }catch (Exception e){                e.printStackTrace();            }        }    }    public static void main(String[] args) {        int threadNum = 5;        CyclicBarrier barrier = new CyclicBarrier(threadNum, new Runnable() {            @Override            public void run() {                System.out.println(Thread.currentThread().getName() + "完成任务");            }        });        for (int i = 0; i < threadNum; i++) {            new TaskThread(barrier).start();        }    }}


推荐阅读


上一篇：什么是网络钓鱼攻击？

下一篇：没有了