经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Java » 查看文章
今天我们来聊一聊Java中的Semaphore
来源:cnblogs  作者:JavaBuild  时间:2024/4/15 9:49:51  对本文有异议

写在开头

在上几天写《基于AQS手写一个同步器》时,很多同学留言说里面提到的Semaphore,讲得太笼统了,今天趁着周末有空,咱们就一起详细的学习和梳理一把 Semaphore

什么是Semaphore?

在前面我们讲过的synchronized 和 ReentrantLock 都是一次只允许一个线程访问某个资源,而Semaphore(信号量)可以用来控制同时访问特定资源的线程数量,多线程同时操作共享资源,仍然存在着线程不安全问题,要想多线程安全,理应结合锁进一步保障。

Semaphore的主要结构

我们跟进信号量的源码中浏览一圈,发现其实它内部主要的方法就2个:

  1. // 初始共享资源数量
  2. final Semaphore semaphore = new Semaphore(5);
  3. // 获取1个许可
  4. semaphore.acquire();
  5. // 释放1个许可
  6. semaphore.release();

① acquire():获取许可

跟进这个方法后,我们会发现其内部调用了AQS的一个final 方法acquireSharedInterruptibly(),这个方法中又调用了tryAcquireShared(arg)方法,作为AQS中的钩子方法,这个方法的实现在Semaphore的两个静态内部类 FairSync(公平模式)NonfairSync(非公平模式) 中。

【源码解析1】

  1. /**
  2. * 获取1个许可证
  3. */
  4. public void acquire() throws InterruptedException {
  5. sync.acquireSharedInterruptibly(1);
  6. }
  7. /**
  8. * 共享模式下获取许可证,获取成功则返回,失败则加入阻塞队列,挂起线程
  9. */
  10. public final void acquireSharedInterruptibly(int arg)
  11. throws InterruptedException {
  12. if (Thread.interrupted())
  13. throw new InterruptedException();
  14. // 尝试获取许可证,arg为获取许可证个数,当可用许可证数减当前获取的许可证数结果小于0,则创建一个节点加入阻塞队列,挂起当前线程。
  15. if (tryAcquireShared(arg) < 0)
  16. doAcquireSharedInterruptibly(arg);
  17. }

继续跟入tryAcquireShared(arg)方法,虽然它在AQS中,但它作为钩子方法,最终的实现则回到了Semaphore的内部类中。

钩子方法: 一种抽象类中的方法,一般使用 protected 关键字修饰,可以给与默认实现,空方法居多,其内容逻辑由子类实现,为什么不适用抽象方法呢?因为,抽象方法需要子类全部实现,增加大量代码冗余!

image

【扩展】

  1. FairSync(公平模式): 调用 acquire() 方法的顺序就是获取许可证的顺序,遵循 FIFO;
  2. NonfairSync(非公平模式): 抢占式的,在构造方法中通过一个布尔值fair来配置公平与非公平,默认为非公平模式。

② release():释放许可

同样跟入这个方法,里面用了AQS的releaseShared(),而在这个方法内也毫无疑问的用了tryReleaseShared(int arg)这个钩子方法,原理同上,不再冗释,需要注意的是释放共享锁的同时也会唤醒同步队列中的一个线程。

【源码解析2】

  1. // 释放一个许可证
  2. public void release() {
  3. sync.releaseShared(1);
  4. }
  5. // 释放共享锁,同时会唤醒同步队列中的一个线程。
  6. public final boolean releaseShared(int arg) {
  7. //释放共享锁
  8. if (tryReleaseShared(arg)) {
  9. //唤醒同步队列中的一个线程
  10. doReleaseShared();
  11. return true;
  12. }
  13. return false;
  14. }

Semaphore的使用

OK,讲到这里,把信号量中主要的方法解释完了,我们来写一个小demo感受一下它的使用:

【测试用例1】

  1. public class Test {
  2. private final Semaphore semaphore;
  3. /*构造一个令牌*/
  4. public Test(int acq){
  5. this.semaphore= new Semaphore(acq);
  6. }
  7. public void useSemaphore(){
  8. try {
  9. semaphore.acquire();
  10. // 使用资源
  11. System.out.println("资源开始使用了 " + Thread.currentThread().getName());
  12. Thread.sleep(1000); // 模拟资源使用时间
  13. } catch (InterruptedException e) {
  14. e.printStackTrace();
  15. } finally {
  16. semaphore.release();
  17. System.out.println("资源释放了 " + Thread.currentThread().getName());
  18. }
  19. }
  20. public static void main(String[] args) {
  21. Test test = new Test(3);
  22. for (int i = 0; i < 5; i++) {
  23. new Thread(test::useSemaphore).start();
  24. }
  25. }
  26. }

输出:

  1. 资源开始使用了 Thread-0
  2. 资源开始使用了 Thread-1
  3. 资源开始使用了 Thread-3
  4. 资源释放了 Thread-0
  5. 资源开始使用了 Thread-2
  6. 资源开始使用了 Thread-4
  7. 资源释放了 Thread-1
  8. 资源释放了 Thread-3
  9. 资源释放了 Thread-4
  10. 资源释放了 Thread-2

结尾彩蛋

如果本篇博客对您有一定的帮助,大家记得留言+点赞+收藏呀。原创不易,转载请联系Build哥!

image

如果您想与Build哥的关系更近一步,还可以关注“JavaBuild888”,在这里除了看到《Java成长计划》系列博文,还有提升工作效率的小笔记、读书心得、大厂面经、人生感悟等等,欢迎您的加入!

image

原文链接:https://www.cnblogs.com/JavaBuild/p/18133329

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号