信号量(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月前
|
Java C++
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
38 0
|
2月前
|
运维 API 计算机视觉
深度解密协程锁、信号量以及线程锁的实现原理
深度解密协程锁、信号量以及线程锁的实现原理
49 2
|
3月前
|
Java 数据中心 微服务
Java高级知识:线程池隔离与信号量隔离的实战应用
在Java并发编程中,线程池隔离与信号量隔离是两种常用的资源隔离技术,它们在提高系统稳定性、防止系统过载方面发挥着重要作用。
80 0
|
4月前
利用信号量实现线程顺序执行
【8月更文挑战第24天】本文介绍了如何运用信号量确保多线程程序中线程按预定顺序执行的方法。信号量作为同步机制,可有效控制共享资源访问,防止数据不一致。实现步骤包括:引入必要的头文件(如 `&lt;pthread.h&gt;` 和 `&lt;semaphore.h&gt;`),定义信号量变量(如 `sem_t` 类型),初始化信号量(通常第一个信号量设为1,其余设为0),以及创建线程(每个线程执行特定任务并释放相应信号量)。
|
4月前
|
安全 C++
利用信号量实现线程顺序执行
【8月更文挑战第25天】信号量是多线程编程中用于控制共享资源访问的关键同步机制,能有效保证线程按预设顺序执行。实现方法包括:引入相关头文件(如 C++ 中的 `&lt;semaphore.h&gt;`),创建信号量并通过 `sem_init` 设置初始值;在各线程函数中运用 `sem_post` 与 `sem_wait` 来传递执行权;最后,通过 `sem_destroy` 销毁信号量以释放资源。使用过程中需注意错误处理、确保线程安全及合理设定信号量初值,以维持程序稳定性和高效性。
|
4月前
|
数据采集 Java Python
python 递归锁、信号量、事件、线程队列、进程池和线程池、回调函数、定时器
python 递归锁、信号量、事件、线程队列、进程池和线程池、回调函数、定时器
|
5月前
|
监控 Cloud Native Java
通用快照方案问题之Hystrix和Ribbon在超时设置上的冲突如何解决
通用快照方案问题之Hystrix和Ribbon在超时设置上的冲突如何解决
60 0
|
4天前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
15 1
|
2月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
60 1
|
2月前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
32 3