信号量(Semaphore)与线程计数器(CountDownLatch)(详解)

简介: 信号量(Semaphore)与线程计数器(CountDownLatch)(详解)

🍉信号量(Semaphore)

Semaphore属于共享锁,即多个线程可以同时获取,用来表示可用资源的个数,本质上是一个计数器

🥩理解信号量:

🍂我们将信号量理解为一个停车场的空车位,例如当前有100个空车位,表示100个可用资源 🍂当有车开进停车场,就相当于申请一个可用资源,空车位就-1(这个称为信号量的P操作) 🍂当有车开出停车场,就相当于释放一个可用资源,空车位就+1(这个称为信号量的V操作) 🍂如果可用资源为0,会尝试申请资源,就会阻塞等待,直到有其他线程释放资源

🥩注意: Semaphore的PV操作的加减计数器操作都是原子性的,可以直接在多线程环境下使用

🍡Semaphore的构造方法:

image.png

🍭Semaphore的常用方法:

image.png

🍢使用场景:

☘️等待一组线程执行完,再执行某个任务

☘️同一个时间最多执行n个线程(有限资源的使用)

🍴示例:

创建Semaphore实例,初始化为4,表示4个可用资源

acquire方法表示申请资源(P操作),release方法表示释放资源(V操作)

创建20个线程,每个线程都尝试申请资源,sleep等待1秒后,释放资源,观察程序执行结果

👁‍🗨️代码展示:


import java.util.concurrent.Semaphore;
public class SemaphoreTest {
    public static void main(String[] args) {
        Semaphore sem = new Semaphore(4);
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                try {
                    System.out.println("申请资源");
                    sem.acquire();
                    System.out.println("获取到资源");
                    Thread.sleep(1000);
                    sem.release();
                    System.out.println("释放资源");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        };
        for(int i = 0;i < 20;i++){
            Thread t = new Thread(runnable);
            t.start();
        }
    }
}

👁‍🗨️打印结果说明:

image.png

🥭线程计数器(CountDownLatch)

CountDownLatch也属于共享锁,其内部有一个int类型的属性表示可以同时并发并行的线程的数量

同时等待N个任务执行结束

举例说明:

比如跑步比赛,必须等所有运动员通过终点才能公布成绩

🍭CountDownLatch的构造方法:

image.png

🍡CountDownLatch的常用方法:

image.png

🥩使用场景: 等待多个线程全部执行完,再执行某个任务

🥩注意: CountDownLatch只能减不能加

🍴示例:

构造CountDownLatch实例,初始化为10,表示有10个任务需要完成

每个任务执行完成后,调用countDown(),CountDownLatch内部计数器自减

主线程调用await(),等待所有线程执行完毕,也就是计数器值为0,再继续执行主线程后续任务

👁‍🗨️代码展示:


import java.util.concurrent.CountDownLatch;
public class CountDownLatchTest {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(10);
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName());
                latch.countDown();
            }
        };
        for(int i = 0;i < 10;i++){
            Thread t = new Thread(runnable);
            t.start();
        }
        latch.await();
        System.out.println("10个线程比赛结束");
    }
}

👁‍🗨️打印结果说明:

image.png



相关文章
|
2月前
|
Python
如何在Python中使用Semaphore来实现线程同步?
如何在Python中使用Semaphore来实现线程同步?
27 7
|
4月前
|
Java 测试技术
CountDownLatch、CyclicBarrier让线程听我号令
CountDownLatch、CyclicBarrier让线程听我号令
42 0
|
2月前
|
算法 安全 Unix
【C++ 20 信号量 】C++ 线程同步新特性 C++ 20 std::counting_semaphore 信号量的用法 控制对共享资源的并发访问
【C++ 20 信号量 】C++ 线程同步新特性 C++ 20 std::counting_semaphore 信号量的用法 控制对共享资源的并发访问
33 0
|
2月前
|
存储 Java 数据库连接
线程通信(CountDownLatch、CyclicBarrier、Semaphore、Exchanger)
线程通信(CountDownLatch、CyclicBarrier、Semaphore、Exchanger)
34 0
|
4月前
|
前端开发 Java BI
自定义线程池+countdownlatch
自定义线程池+countdownlatch
22 0
|
4月前
|
数据处理 容器
RT-Thread快速入门-线程间同步之信号量
RT-Thread快速入门-线程间同步之信号量
31 0
|
5月前
|
安全 Java C++
多线程之Callable接口、ReentrantLock、信号量 Semaphore以及CountDownLatch
多线程之Callable接口、ReentrantLock、信号量 Semaphore以及CountDownLatch
|
5月前
学习多线程之CountDownLatch使用
学习多线程之CountDownLatch使用
18 0
|
5月前
学习多线程之Semaphore工具解释
学习多线程之Semaphore工具解释
27 0
|
5月前
多线程并发之Semaphore(信号量)使用详解
多线程并发之Semaphore(信号量)使用详解
96 0