多线程之倒计时器CountDownLatch和循环栅栏CyclicBarrier

Posted SheaChen

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多线程之倒计时器CountDownLatch和循环栅栏CyclicBarrier相关的知识,希望对你有一定的参考价值。

1、倒计时器CountDownLatch
CountDownLatch是一个多线程控制工具类。通常用来控制线程等待,它可以让一个线程一直等待知道计时结束才开始执行
构造函数:
public CountDownLatch(int count) //count 计数个数

例如:在主线程中启动10个子线程去数据库中获取分页数据,需要等到所有线程数据都返回之后统一做统计处理

public class CountDownLatchDemo implements Runnable{
private static final CountDownLatch end = new CountDownLatch(10);
@Override
public void run() {
System.out.println("线程名称:" + Thread.currentThread().getName());
//数据业务处理
end.countDown();//计数减1
}

public static void main(String[] args) {
    CountDownLatchDemo countDownLatchDemo = new CountDownLatchDemo();
    System.out.println("计数开始");
    for (int i = 0; i < 10; i++) {
        new Thread(countDownLatchDemo).start();
    }
    try {
        end.await();
        System.out.println("计数结束");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

}

上述代码使用CountDownLatch的await()方法,要求主线程等待所有10个计数任务全部完成后,主线程才开始继续执行
可以通过getCount()方法获取当前的计数个数,当计数结束时count为0,且不会被重置

2、循环栅栏CyclicBarrier
CyclicBarrier也是一种多线程并发控制的工具。相比CountDownLatch,CyclicBarrier功能更加强大,主要表现在:
1)构造方法:
public CyclicBarrier(int parties, Runnable barrierAction)
CyclicBarrier的构造方法可以传入一个Runnable的barrierAction,可用于线程集结完毕后做一件特定的事情
2)CyclicBarrier可以重复使用,当一批线程凑满parties个是,计数器会归零,重新开始计数

public class CyclicBarrierDemo {

class Soldier implements Runnable{
    private CyclicBarrier cyclicBarrier;
    public Soldier(CyclicBarrier cyclicBarrier){
        this.cyclicBarrier = cyclicBarrier;
    }

    @Override
    public void run() {
        System.out.println("士兵 " + Thread.currentThread().getId() + " 报道");
        try {
            //等待所有士兵到齐
            cyclicBarrier.await();
            //执行任务
            doWork();
            cyclicBarrier.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }

    private void doWork() throws InterruptedException {
        Thread.sleep(1000);
        System.out.println("士兵" + Thread.currentThread().getId()+ " 任务完成");
    }
}

class Commond implements Runnable{
    @Override
    public void run() {
        System.out.println("任务结束");
    }
}

public static void main(String[] args) {
    CyclicBarrierDemo cyclicBarrierDemo = new CyclicBarrierDemo();
    CyclicBarrier cyclicBarrier = new CyclicBarrier(5, cyclicBarrierDemo.new Commond());
    for (int i = 0; i < 20; i++) {
        new Thread(cyclicBarrierDemo.new Soldier(cyclicBarrier)).start();
    }

}

}

执行结果:

可以看到,线程被分成了5个一组

以上是关于多线程之倒计时器CountDownLatch和循环栅栏CyclicBarrier的主要内容,如果未能解决你的问题,请参考以下文章

JUC并发编程 共享模式之工具 JUC CyclicBarrier(循环栅栏 与CountdownLatch最大的不同是可以重值倒计时) -- CyclicBarrier介绍使用注意事项

JAVA私房菜专栏之AQS

JUC并发编程 共享模式之工具 JUC CountdownLatch(倒计时锁) -- CountdownLatch(使用CountdownLatch原理改进: 配合线程池使用)

Java多线程-两种常用的线程计数器CountDownLatch和循环屏障CyclicBarrier

JUC并发编程 共享模式之工具 JUC CountdownLatch(倒计时锁) -- CountdownLatch应用(等待多个线程准备完毕( 可以覆盖上次的打印内)等待多个远程调用结束)(代码片段

多线程之CountDownLatch