网站首页 > 精选教程 正文
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
- 上一篇: Java系统过载保护机制之信号量的控制
- 下一篇: 一个java同步工具类Semaphore的详解
猜你喜欢
- 2024-11-06 信号量限流,高并发场景不得不说的秘密
- 2024-11-06 面试卡在多线程?那就分享几道Java多线程高频面试题,面试不用愁
- 2024-11-06 Java并发系列之Semaphore源码分析
- 2024-11-06 Java多线程与并发 java的并发,多线程,线程模型
- 2024-11-06 66.java并发编程之Semaphore和CountDownLatch使用
- 2024-11-06 Java基础笔试练习(十五) java基础知识试题
- 2024-11-06 72道Java线程面试题,这些面试官必问
- 2024-11-06 Java并发基础-锁详细分析(可重入锁、读写锁、信号量等)
- 2024-11-06 Java并发工具:CountDownLatch CyclicBarrier Semaphore快速掌握
- 2024-11-06 死磕 java同步系列之Semaphore源码解析
你 发表评论:
欢迎- 04-11Java面试“字符串三兄弟”String、StringBuilder、StringBuffer
- 04-11Java中你知道几种从字符串中找指定的字符的数量
- 04-11探秘Java面试中问的最多的String、StringBuffer、StringBuilder
- 04-11Python字符串详解与示例(python字符串的常见操作)
- 04-11java正则-取出指定字符串之间的内容
- 04-11String s1 = new String("abc");这句话创建了几个字符串对象?
- 04-11java判断字符串中是否包含某个字符
- 04-11关于java开发中正确的发牌逻辑编写规范
- 最近发表
-
- Java面试“字符串三兄弟”String、StringBuilder、StringBuffer
- Java中你知道几种从字符串中找指定的字符的数量
- 探秘Java面试中问的最多的String、StringBuffer、StringBuilder
- Python字符串详解与示例(python字符串的常见操作)
- java正则-取出指定字符串之间的内容
- String s1 = new String("abc");这句话创建了几个字符串对象?
- java判断字符串中是否包含某个字符
- 关于java开发中正确的发牌逻辑编写规范
- windows、linux如何后台运行jar(并且显示进程名)
- 腾讯大佬私人收藏,GitHub上最受欢迎的100个JAVA库,值得学习
- 标签列表
-
- nginx反向代理 (57)
- nginx日志 (56)
- nginx限制ip访问 (62)
- mac安装nginx (55)
- java和mysql (59)
- java中final (62)
- win10安装java (72)
- java启动参数 (64)
- java链表反转 (64)
- 字符串反转java (72)
- java逻辑运算符 (59)
- java 请求url (65)
- java信号量 (57)
- java定义枚举 (59)
- java字符串压缩 (56)
- java中的反射 (59)
- java 三维数组 (55)
- java插入排序 (68)
- java线程的状态 (62)
- java异步调用 (55)
- java中的异常处理 (62)
- java锁机制 (54)
- java静态内部类 (55)
- java怎么添加图片 (60)
- java 权限框架 (55)
本文暂时没有评论,来添加一个吧(●'◡'●)