多线程之Semaphore信号量

一、什么是信号量

Semaphore(信号量)是用来控制同时访问特定资源的线程数量,它通过协调各个线程,以保证合理的使用公共资源。在多线程中经常会遇到该应用场景,信号量如同交通公路中的红绿灯一样,需要限流,举例如下:

高速路线的承载有限,只能允许100辆车在高速路行驶,如何控制呢?就需要红路灯来限制,若发现高速路段路段有100辆车,则信号量控制,不让车驶入;若发现有10辆车驶出,则信号量方向10辆车;

二、多线程中的应用

Semaphore semaphore = new Semaphore(5);
System.out.println("开始");
for(int i = 0;i < 10; i++) {CompletableFuture.runAsync(() -> {try {semaphore.acquire();System.out.println(Thread.currentThread().getId() + "异步线程aaaaaaaaa");ThreadUtil.sleep(1000 * 1);} catch (InterruptedException e) {throw new RuntimeException(e);} finally {semaphore.release();}});
}

初始化5个信号量,CompletableFuture异步线程获取一个许可,然后线程等待1s,执行时候发现,第一秒打印5条,第二秒打印5条;若初始化信号量10个,则执行发现第一秒打印10条。

三、信号量的其他方法

1.semaphore.acquire(5) 获取5个信号量,每次全部获取,则线程都会等待

2.semaphore.tryAcquire() 尝试获取一个许可,如果未获取到,不等待,将直接丢弃该线程不执行
 

        Semaphore semaphore = new Semaphore(5);System.out.println("开始");for(int i = 0;i < 10; i++) {CompletableFuture.runAsync(() -> {if(semaphore.tryAcquire()) {System.out.println(Thread.currentThread().getId() + "异步线程aaaaaaaaa");ThreadUtil.sleep(1000 * 1);semaphore.release();}});}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/60419.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

MySQL 迁移 dm

参考链接 此处为语雀内容卡片&#xff0c;点击链接查看&#xff1a;MySQL 5.7.27 迁移 DM 8 语雀 迁移前准备 以下中的命名&#xff0c;密码都是可修改的&#xff0c;这里给出的就只是一个例子 创建表空间 # 创建表空间名为 dbTest&#xff0c;路径为 Z:\fei\data\dm\dbT…

新版IJidea 如何打开数据库窗口(2024.2.4 版)(连接数据库)

新版IJidea 2024.2.4 如何打开数据库窗口&#xff1f; 方式&#xff1a;使用插件&#xff0c;Database Navigator 1.安装插件&#xff0c;步骤如下&#xff1a; 打开 Settings/Preferences 对话框&#xff08;快捷键 CtrlAltS&#xff09;。前往 Plugins 菜单项。在搜索框中…

go map 映射

1、数据结构 // A header for a Go map. type hmap struct {// Note: the format of the hmap is also encoded in cmd/compile/internal/reflectdata/reflect.go.// Make sure this stays in sync with the compilers definition.count int // # live cells size of map.…

MySQL:left join后用on与where的区别

一、前言 前几天项目中&#xff0c;写SQL时本想通过 A left B join on and 后面的条件来使查出的两条记录变成一条&#xff0c;奈何发现还是有两条。在此记录一下&#xff0c;on与where的区别。 二、ON 原始数据展示 SELECT t1.*,t2.* FROM t_test_staff t1 left join t_te…

Unity 性能优化方案

‌Unity性能优化的主要方案包括以下几个方面‌&#xff1a; 一、减少Draw Call‌ Draw Call就是CPU调用图形编程接口&#xff0c;是CPU向GPU发送的命令 1.CPU和GPU并行工作的原理 CPU和GPU工作有一个命令缓冲区(Command Buffer) 命令缓冲区包含了一个命令队列&#xff0c;由C…

Spark 核心概念与宽窄依赖的详细解析

Spark 的介绍与搭建&#xff1a;从理论到实践_spark环境搭建-CSDN博客 Spark 的Standalone集群环境安装与测试-CSDN博客 PySpark 本地开发环境搭建与实践-CSDN博客 Spark 程序开发与提交&#xff1a;本地与集群模式全解析-CSDN博客 Spark on YARN&#xff1a;Spark集群模式…

快速删除图片脚本

电脑上存了几百万张小图片,让电脑慢慢删除了5个小时还没有删完,就写了一个python脚本,开启多线程删除,调整线程数量,让CPU和硬盘占有率都到100%,1个小时就删除了.感谢这段代码哈. 逻辑为删除当前目录下所有二级子目录中的文件&#xff0c;每个二级子目录由一个线程处理,每当一个…

【树莓派raspberrypi烧录Ubuntu远程桌面登入树莓派】

提示&#xff1a;本文利用的是Ubuntu主机和树莓派4B开发板&#xff0c;示例仅供参考 文章目录 一、树莓派系统安装下载前准备工作下载安装树莓派的官方烧录软件imagerimager的使用方法 二、主机与树莓SSH连接查看数梅派IP地址建立ssh连接更新树莓派源地址 三、主机端远程桌面配…

MySQL数据库专栏(四)MySQL数据库链接操作C#篇

摘要 本篇文章主要介绍C#链接MySQL数据库的接口介绍&#xff0c;使用实例及注意事项&#xff0c;辅助类的封装及调用实例&#xff0c;可以直接移植到项目里面使用。 目录 1、添加引用 2、接口介绍 2.1、MySqlConnection 2.2、MySqlCommand 2.3、MySqlDataReader…

百度世界2024:AI应用的浪潮时刻

百度AI公式&#xff1a;“技术商业社会”。 作者|金豫 编辑|杨舟 互联网行业正迈入增长瓶颈期&#xff0c;这一点从主要科技巨头&#xff0c;如Meta、Alphabet、腾讯等近年来的表现中可见端倪&#xff1a;广告收入增速放缓&#xff0c;市场渗透率接近饱和。 单纯依赖流量获取…

Linux 通过nmcli配置网络并配置bond(网卡绑定)

Linux 通过nmcli配置网络并配置bond Linux 通过nmcli配置网络并配置bond1. 什么是 Bond 网卡绑定2. Bond 网卡绑定的常见模式3. 通过nmcli配置网络并做网卡绑定 Linux 通过nmcli配置网络并配置bond 1. 什么是 Bond 网卡绑定 Bond 网卡绑定&#xff08;或 NIC Bonding&#xff…

PCL 点云拟合 最小二乘法拟合平面

目录 一、概述 1.1原理 1.2实现步骤 1.3应用场景 二、代码实现 2.1关键函数 2.1.1计算点云质心 2.1.2最小二乘法拟合平面 2.1.3可视化函数 2.2完整代码 三、实现效果 PCL点云算法汇总及实战案例汇总的目录地址链接: PCL点云算法与项目实战案例汇总(长期更新) 一…

【Stable Diffusion - Ai】小白入门必看(想控制AI的绘画结果?ControlNet 预处理篇)!真材实料!不卖课!!!

【Stable Diffusion - Ai】小白入门必看&#xff08;想控制AI的绘画结果&#xff1f;ControlNet 预处理篇&#xff09;&#xff01;真材实料&#xff01;不卖课&#xff01;&#xff01;&#xff01; 对于ControlNet来说&#xff0c;很多人都会感觉到陌生&#xff1b;这个插件…

几何合理的分片段感知的3D分子生成 FragGen - 评测

FragGen 来源于 2024 年 3 月 25 日 预印本的文章&#xff0c;文章题目是 Deep Geometry Handling and Fragment-wise Molecular 3D Graph Generation&#xff0c; 作者是 Odin Zhang&#xff0c;侯廷军&#xff0c;浙江大学药学院。FragGen 是一个基于分子片段的 3D 分子生成模…

Mysql事务中的一些问题,还有解决方法原理(ACID、脏读幻读重复读、next-key)

** 首先&#xff0c;事务是什么&#xff1f; ** 是一系列或者一组sql操作看作一个整体&#xff0c;作为一个事务&#xff0c;这一组sql要么都执行&#xff0c;要么都不执行。当所有sql都能执行成功的时候&#xff0c;commit当前事务&#xff0c;当其中一个sql出现问题时&…

【设计模式系列】享元模式(十五)

目录 一、什么是享元模式 二、享元模式的角色 三、享元模式的典型应用场景 四、享元模式在ThreadPoolExecutor中的应用 1. 享元对象&#xff08;Flyweight&#xff09;- 工作线程&#xff08;Worker&#xff09; 2. 享元工厂&#xff08;Flyweight Factory&#xff09;- …

为什么分布式光伏规模是6MW为界点

安科瑞 华楠 近日&#xff0c;能源局发布定义分布式光伏6MW及以上的光伏电站必须自发自用&#xff0c;自行消纳。多省能源局规定大于6MW的电站必须按集中式管理&#xff0c;另外大于6MW&#xff08;包含&#xff09;要省级审批&#xff0c;小于则由市级审批&#xff0c;10kV线…

RDD 算子全面解析:从基础到进阶与面试要点

Spark 的介绍与搭建&#xff1a;从理论到实践_spark环境搭建-CSDN博客 Spark 的Standalone集群环境安装与测试-CSDN博客 PySpark 本地开发环境搭建与实践-CSDN博客 Spark 程序开发与提交&#xff1a;本地与集群模式全解析-CSDN博客 Spark on YARN&#xff1a;Spark集群模式…

如何利用 CAS 实现原子操作:深入浅出原子类与线程安全

在并发编程中&#xff0c;确保线程安全是一个重要话题。为了避免多个线程对同一数据进行竞争访问&#xff0c;Java 提供了原子类&#xff08;Atomic Classes&#xff09;来保证并发场景下的线程安全&#xff0c;而原子类最核心的实现机制就是 CAS&#xff08;Compare And Swap&…

四万字长文SpringBoot、Spring、SpringMVC等相关面试题(注:该篇博客将会持续维护 最新维护时间:2024年11月12日)

&#x1f9f8;本篇博客重在讲解SpringBoot、Spring、SpringMVC等相关面试题&#xff0c;将会实时更新&#xff0c;欢迎大家添加作者文末联系方式交流 &#x1f4dc;JAVA面试题专栏&#xff1a;JAVA崭新面试题——2024版_dream_ready的博客-CSDN博客 &#x1f4dc;作者首页&…