网站首页 > 教程文章 正文
java.util.concurrent.Semaphore类是个计数信号量,也就意味着它有两个主要的方法:
- acquire()
- release()
计数信号量初始化时候设置了一个给定的数字“permits(许可证)”
看下构造函数:
public Semaphore(int permits) {
sync = new NonfairSync(permits);
}
public Semaphore(int permits, boolean fair) {
sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}
对于调用acquire()的每个线程都会获取一个许可证。对于每个release()调用的线程都会号量返回一个许可证。因此,最多有N个线程可以在不调用release()的情况下调用acquire()方法,其中N是初始化信号量的许可证数。许可证只是一个简单的计数器。这里没什么特别的。
Semaphore用法
Semaphore常见的两种用法:
- 保证不超过N个线程进入临界区。
- 多个线程间互相传递信号。
保护临界区
如果使用semaphore保护关键部分,尝试进入临界区的线程通常会先尝试获取许可证,进入临界区,然后再释放许可证。看下面代码:
Semaphore semaphore = new Semaphore(1);
//critical section
semaphore.acquire();
...
semaphore.release();
线程间传递信号
如果用semaphore用于线程间传递信号,典型的用法是一个线程调用acquire(),另一个线程调用release()。
如果没有许可证可用,调用acquire()将阻塞直到其他线程释放。相似的,如果没有许可证可返回给semaphore那么调用release()方法将阻塞。因此可以协调线程,比如,如果线程1调用acquire()并且将一个对象插入到共享list中,线程2在从该列表中获取对象之前调用了release(),实际上,你已经创建了一个阻塞队列,信号量中可用的许可证数量将与阻塞队列可以容纳的最大元素数相对应
公平
对于从信号量获取许可的线程的公平性没有任何保证,也就是不能保证第一个调用 acquire()的线程也第一个获取许可证。如果第一个线程阻塞了在等待许可证,当许可证被释放时,第二个线程检查许可证,实际可能在第一个线程之前获取许可证。
如果需要强制实行公平,那么semaphore构造函数有个boolean类型的参数可以设置,构造函数我们在上面已经有:
public Semaphore(int permits, boolean fair) {
sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}
强制执行公平性会带来性能/并发性损失,因此除非需要,否则不要启用它,下面是创建一个公平的Semaphore :
Semaphore semaphore = new Semaphore(1, true);
更多方法
java.util.concurrent.Semaphore 有许多方法比如:
- availablePermits()
- acquireUninterruptibly()
- drainPermits()
- hasQueuedThreads()
- getQueuedThreads()
- tryAcquire()
- etc.
这些方法的更多细节可以参看java官方文档。
参考:1.http://tutorials.jenkov.com/java-util-concurrent/semaphore.html
2. http://tutorials.jenkov.com/java-concurrency/semaphores.html
3. https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Semaphore.html
猜你喜欢
- 2024-12-26 进程间通信:共享内存和信号量的统一封装机制原理与实现
- 2024-12-26 python基础篇:多线程的基本使用 python3.9多线程
- 2024-12-26 介绍C#中的并发集合,并说明其在多线程编程中的作?
- 2024-12-26 Hystrix系列之信号量、线程池 信号量 线程池
- 2024-12-26 劳斯莱斯推出独一无二的Spectre Semaphore:车头泼墨,极致奢华
- 2024-12-26 Linux信号量(1)-SYSTEM V Linux信号量做进程同步
- 2024-12-26 什么是多线程同步?请列举多种多线程同步机制并?较它们的优缺点
- 2024-12-26 2 万字长文详解 10 大多线程面试题|原力计划
- 2024-12-26 进程间通信——POSIX 有名信号量与无名信号量
- 2024-12-26 Python并发编程:使用信号量Semaphore实现资源有限的并发场景
- 最近发表
- 标签列表
-
- location.href (44)
- document.ready (36)
- git checkout -b (34)
- 跃点数 (35)
- 阿里云镜像地址 (33)
- qt qmessagebox (36)
- md5 sha1 (32)
- mybatis plus page (35)
- semaphore 使用详解 (32)
- update from 语句 (32)
- vue @scroll (38)
- 堆栈区别 (33)
- 在线子域名爆破 (32)
- 什么是容器 (33)
- sha1 md5 (33)
- navicat导出数据 (34)
- 阿里云acp考试 (33)
- 阿里云 nacos (34)
- redhat官网下载镜像 (36)
- srs服务器 (33)
- pico开发者 (33)
- https的端口号 (34)
- vscode更改主题 (35)
- 阿里云资源池 (34)
- os.path.join (33)