百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

JAVA并发之Semaphore(信号量)(java并发大神)

haoteby 2025-07-08 18:08 7 浏览

前面几篇文章我们讲了可重入锁和读写锁(见文末链接),本篇文章主要讲下Java并发包下面另一个工具类Semaphore(信号量)的原理。

Semaphore特点

  1. 是一种共享锁(类似于读写锁中的读锁)
  2. 基于AQS实现(AQS相关内容可以参考文末链接)
  3. 允许一定数量的线程获得锁

Semaphore例子

JDK源码对Semaphore的介绍是可以用来限制一定数量的线程访问某个资源,下面我们通过一个例子来看下具体是什么意思。

public static void main(String[] args) {
        DateFormat df = new SimpleDateFormat("HH:mm:ss---");
        Semaphore semaphore = new Semaphore(3);
        
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                try {
                    semaphore.acquire();
                    System.out.println(df.format(new Date()) + Thread.currentThread().getName() + " got resource");
                    Thread.sleep(2000);
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    semaphore.release();
                }
            }
        };
        
        for (int i = 0; i < 9; i++) {
            new Thread(runnable, "Thread" + i).start();
        }
}

上例中,我们创建了一个限制是3的信号量,同时启动了9个线程去执行各自的任务(这里都休眠了2秒钟),从下面打印的结果我们可以看到,同时只有3个线程能够获得信号量并执行。

11:12:29---Thread1 got resource
11:12:29---Thread3 got resource
11:12:29---Thread0 got resource
11:12:31---Thread4 got resource
11:12:31---Thread2 got resource
11:12:31---Thread6 got resource
11:12:33---Thread5 got resource
11:12:33---Thread7 got resource
11:12:33---Thread8 got resource

Semaphore原理

Semaphore内部包含了一个Sync对象继承了AQS,而Sync对象又有两个子类NonfaireSync和FairSync,因此Semaphore也支持公平锁和非公平锁两个功能。

同时,公平锁和非公平锁也体现到了Semaphore的构造函数上面:

//默认非公平锁
public Semaphore(int permits) {
        sync = new NonfairSync(permits);
}
//fair为true时表示公平锁
public Semaphore(int permits, boolean fair) {
        sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}

获取Semaphore锁的方法如下,其主要方法有两个:

public final void acquireSharedInterruptibly(int arg)
            throws InterruptedException {
        if (Thread.interrupted())
            throw new InterruptedException();
        if (tryAcquireShared(arg) < 0)
            doAcquireSharedInterruptibly(arg);
}

tryAcquireShared:尝试去获取锁,获取成功则返回正数或0,获取失败返回负数。

这里公平锁和非公平锁有不同的实现逻辑:

公平锁:前线程检查如果AQS里面有线程在排队了,则当返回-1,进入AQS排队;否则和其他线程竞争获取锁,竞争成功则获取锁返回,竞争失败则进入AQS排队。

protected int tryAcquireShared(int acquires) {
            for (;;) {
                if (hasQueuedPredecessors())
                    return -1;
               // 通过state来做线程数量限制
               // state的值和构造函数里面的permits参数是一个值
                int available = getState();
                int remaining = available - acquires;
                if (remaining < 0 ||
                    compareAndSetState(available, remaining))
                    return remaining;
            }
}

非公平锁:当前线程直接参与获取锁的竞争,竞争成功则获取锁返回,竞争失败则进入AQS排队(不考虑是否AQS已经有其他线程在排队)。

final int nonfairTryAcquireShared(int acquires) {
            for (;;) {
                int available = getState();
                int remaining = available - acquires;
                if (remaining < 0 ||
                    compareAndSetState(available, remaining))
                    return remaining;
            }
}


doAcquireSharedInterruptibly:
类似于读锁调用的doAcquireShared方法,如果当前线程获取到锁,则唤醒它在AQS的后继结点,否则进入AQS排队。


释放Semaphore锁比较简单,公平锁和非公平锁都是一样的逻辑:

将state数值加1,并且唤醒正在AQS排队的其他线程。


Demo代码位置


src/main/java/net/weichitech/juc/SemaphoreTest.java · 小西学编程/java-learning - Gitee.com

相关文章

JAVA并发之ReentrantLock原理解析

JAVA并发之ReentrantReadWriteLock原理解析(一)

JAVA并发之ReentrantReadWriteLock原理解析(二)

相关推荐

手把手教你构建一个简单的Eclipse RCP应用

EclipseRCP应用,通常用来构建跨平台的图形化管理客户端,Eclipse从IBM开源以来,一直占据开源Java开发平台的头把交椅,现在仍然收到很多人的追捧。今天就带大家通过一个简单的例子:开发...

Eclipse配置maven 环境(maven的配置、以及eclipse中配置maven)

Eclipse配置maven环境的先决条件是,Windows系统已经配置好maven环境Eclipse配置maven环境步骤如下:一、给Eclipse添加本地maven...

如何在Eclipse中搭建Zabbix源码的调试和开发环境

Zabbix是一款非常优秀的企业级软件,被设计用于对数万台服务器、虚拟机和网络设备的数百万个监控项进行实时监控。Zabbix是开放源码和免费的,这就意味着当出现bug时,我们可以很方便地通过调试源码来...

Eclipse中将现有的maven项目 导入Git,并发布到

Eclipse中将现有的maven项目导入Git,并发布到github一、Eclipse中将现有的maven项目导入Git1.将本地的maven项目,添加他的子项目到git仓库,并发布到githu...

eclipse安装图解(eclipse安装教程2021)

下载eclipse之前请先安装jdk、查看自己电脑系统是多少位第一步:打开官网https://www.eclipse.org/downloads/第二步:点击DownloadPackages第三...

Eclipse IDE for C/C++ Developers 开发环境搭建详解

EclipseIDEforC/C++Developers开发环境搭建详解1.到官网下载eclipseforC/C++Developmer解压就行2.下载MinGW用来编译C/C+...

来来来!一文告诉你Eclipse的正确安装使用姿势,你都清楚吗?

前言本学习笔记是有关如何设置Eclipse的详细说明。即使你天天在使用它,但是,相信我,或许你并不足够了解它。安装Java运行时环境Eclipse是Java应用程序,因此设置Eclipse的第一步是安...

纯干货!Eclipse的安装与使用(eclipse 安装教程)

之前有人给小华君留言,说让小华君讲一讲Eclipse,那好,我们今天就简单地讲一下。讲得也是基础部分,如题,主要是Eclipse的安装与使用。废话不多说,开始讲。Eclipse是Java开发的集成开发...

2020 最新版jdk &amp; eclipse下载安装 之JDK(一)

首次安装Eclipse,去官网下载资源找不对安装包,安装之后又报错,如果和我一样的话,那就来看我的分享吧安装eclipse前,需要先安装JDK软件首先,到oracle官网下载JDK安装包下载链接:...

Eclipse 安装教程(附安装包下载)(eclipse安装教程最新版)

Eclipse软件介绍是一个开放源代码、基于Java的可扩展开发平台。它本身只是一个框架和一组服务,通过插件组件构建开发环境。幸运的是,Eclipse附带了一个标准的插件集,包括Java开发工具(Ja...

JDK安装、Eclipse安装及运行环境配置

1、eclipse下载打开地址:http://www.eclipse.org/downloads/;根据自己机器的操作系统,页面上显示适应机器操作系统的Eclipse下载列表,也可以点击下图所示位置切...

Ubuntu Linux 21.10官方壁纸现已提供下载 最高8192×4608分辨率

距离十月份的Ubuntu21.10Linux发行版的到来,已只有数周的时间。在今年4月介绍了与之有关的大量细节之后,Canonical现又放出了代号为“ImpishIndri”的这一大...

Linux 4.7系统内核发布:支持RX 480

经过一周休假之后,LinusTorvalds今天正式发布了新版LinuxKernel4.7,可在官网直接下载。Linux4.7版内核的开发启动于5月29日,经过了七个RC候选版,加入了不少新特...

开发企业官网就用这个基于SpringBoot的CMS系统,真香

前言推荐这个项目是因为使用手册部署手册非常...

非常详细的Linux系统安装教程!建议收藏

公众号:老油条IT记一、下载ISO镜像#官网:CentOS:http://mirror-status.centos.org/#cn#其他:网易:http://mirrors.163.com/cento...