CountDownLatch和CyclicBarrier的应用场景

简介:

jdk1.5之后,java的concurrent包提供了一些并发工具类,比如CountDownLatch和CyclicBarrier,这里只讲它们的应用场景,暂不作原理剖析。
CountDownLatch:一个线程A等待其它线程都执行完毕后,这个线程A才继续执行。这个线程A也可以是一组线程(使用同一个CountDownLatch来控制即可).
CyclicBarrier:一组线程互相等待,当它们都达到各自await()指定的barrier时,它们再同时继续执行各自下面的代码。

大致实现如下:

CountDownLatch:使用await()让主线程A等待,然后其它线程执行完成时可以使用countDown()使计数减1,最终计数器被清0时,主线程继续执行,计数器是由CountDownLatch初始化时定义的:

final CountDownLatch latch = new CountDownLatch(2);
CyclicBarrier:一组线程使用await()指定barrier,所有线程都到达各自的barrier后,再同时执行各自barrier下面的代码。CyclicBarrier也可以指定当所有线程到达barrier时执行一段代码:

        @Override
        public void run() {
            System.out.println("大家都到了啊!");   
        }
    });```
还有个工具也很实用,Semaphore,可以控制一段代码块同时被访问的线程的个数。通过 acquire() 获取一个许可,如果没有就等待,而 release() 释放一个许可。

public static void main(String[] args) {

int N = 8;            //总线程数
Semaphore semaphore = new Semaphore(5); //最多访问线程数5
for(int i=0;i<N;i++)
    new Worker(i,semaphore).start();

}
static class Worker extends Thread{

private int num;
private Semaphore semaphore;
public Worker(int num,Semaphore semaphore){
    this.num = num;
    this.semaphore = semaphore;
}
@Override
public void run() {
    try {
        semaphore.acquire();
        //sleep模拟一个代码块,最多只有5个线程能够执行它,其它线程会被阻塞在上面的acquire()方法,
        等待获取许可
        Thread.sleep(2000);
        semaphore.release();           
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

}
}`

目录
相关文章
|
4月前
|
设计模式 Java
CountDownLatch和CyclicBarrier源码详解
我现在有个场景:现在我有50个任务,这50个任务在完成之后,才能执行下一个函数,要是你,你怎么设计?可以用JDK给我们提供的线程工具类,CountDownLatch和CyclicBarrier都可以完成这个需求。基于AQS实现,会将构造CountDownLatch的入参传递至statecountDown()就是在利用CAS将state减1,await)实际就是让头节点一直在等待state为0时,释放所有等待的线程。
41 1
|
3月前
CountDownLatch和CyclicBarrier你使用过吗?
CountDownLatch和CyclicBarrier你使用过吗?
25 0
|
5月前
CountDownLatch和CyclicBarrier的区别
CountDownLatch和CyclicBarrier的区别
21 0
CountDownLatch和 CyclicBarrier的使用
CountDownLatch和 CyclicBarrier的使用
|
安全 Java 测试技术
CountDownLatch原理剖析
CountDownLatch原理剖析
CountDownLatch、CyclicBarrier的使用(门栓)
CountDownLatch、CyclicBarrier的使用(门栓)
87 0
|
算法 Java 数据库
Java并发:同步工具类详解(CountDownLatch、CyclicBarrier、Semaphore)
Java并发:同步工具类详解(CountDownLatch、CyclicBarrier、Semaphore)
254 0
|
消息中间件
CountDownLatch&CyclicBarrier
CountDownLatch&CyclicBarrier
114 0
CountDownLatch&CyclicBarrier