并发编程-17AQS同步组件之 Semaphore 控制并发线程数的信号量

简介: 并发编程-17AQS同步组件之 Semaphore 控制并发线程数的信号量

2019080611330380.jpg



J.U.C脑图


2019022410360263.png


20190224103319901.png

2019022410351861.png


Semaphore 概述


Semaphore(信号量)是用来控制同时访问特定资源的线程数量,它通过协调各个线程,以保证合理的使用公共资源。

举个例子:

20190224150914365.png


高速要限制流量,只允许同时有一百辆车在这条路上行使,其他的都必须 在路口等待,所以前一百辆车会看到绿灯,可以开进这条高速,后面的车会看到红灯,不能驶入高速,但是如果前一百辆中有5辆车已经离开了高速,那么后面就允许有5辆车驶入高速,这个例子里说的车就是线程,驶入高速就表示线程在执行,离开高速就表示线程执行完成,看见红灯就表示线程被阻塞,不能执行。


Semaphore 构造函数及方法


Semaphore的用法:首先线程使用Semaphore的acquire()方法获取一个许可证,使用完之后调用release()方法归还许可证。

20190224153202710.png


构造函数


Semaphore的构造方法 Semaphore(int permits)接受一个整型的数字,表示可用的许可证数量。Semaphore(10)表示允许10个线程获取许可证,也就是最大并发数是10。

20190224153716193.png

第二个构造函数 Semaphore(int permits, boolean fair) 第二个构造方法指定是公平模式还是非公平模式,默认非公平模式 . 公平模式:先启动的线程优先得到许可。 非公平模式:先启动的线程并不一定先获得许可,谁抢到谁就获得许可。


20190224153815422.png


常用和需要注意的方法


  • acquire() 获取一个许可
  • acquire(int permits) 获取指定个数的许可
  • tryAcquire()方法尝试获取1个许可证
  • tryAcquire(long timeout, TimeUnit unit) 最大等待许可的时间
  • tryAcquire(int permits) 获取指定个数的许可
  • tryAcquire(int permits, long timeout, TimeUnit unit) 最大等待许可的时间
  • availablePermits() : 返回此信号量中当前可用的许可证数
  • release() 释放许可
  • release(int permits) 释放指定个数的许可
  • int getQueueLength() 返回正在等待获取许可证的线程数。
  • boolean hasQueuedThreads() 是否有线程正在等待获取许可证。
  • void reducePermits(int reduction) 减少reduction个许可证。是个protected方法。
  • Collection getQueuedThreads() 返回所有等待获取许可证的线程集合。是个protected方法。

Semaphore 示例

acquire()

20190224161256143.png


观察输出:


20190224161318453.gif



根据上述代码的逻辑,test方法中休眠1秒,设置的3个许可,及同一时间最多只能有3个线程执行,根据日志输出的时间可以看到 符合预期。


semaphore.acquire(int permits)



20190224161731293.png

输出:


20190224161845910.gif


设置了3个许可,每个线程每次获取3个许可,因此同一时间只能有1个线程执行,输出符合预期 。


semaphore.tryAcquire()

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

20190224163636677.png


运行输出:


20190224164219359.gif


从输出可以看到,在3个线程获取到3个许可后,因为每个线程调用的方法要执行1秒中,最早的一个许可也要在1S后释放,剩下的17个线程未获取到许可,使用了semaphore.tryAcquire()方法,没有设置等待时间,所以便直接被丢弃,不执行了。


tryAcquire(long timeout, TimeUnit unit)

未获取到许可,设置等待时长


20190224164728964.png

输出结果:


20190224164837712.gif

tryAcquire通过参数指定了5秒的等待时间。 上述代码中同一时间最多执行3个。第4个线程因前3个线程执行需要耗时一秒未释放许可,因此需要等待。 但是由于设置了5秒的等待时间,所以在5秒内等待到了释放的许可,继续执行,循环往复。但是20个线程 ,每秒并发3个,5S是执行不完的。,所以上面执行到第16个(0开始,显示是15)就结束了,【每次执行结果会有差异,取决于CPU】,并没有全部执行完20个线程。


代码


https://github.com/yangshangwei/ConcurrencyMaster

相关文章
|
5天前
|
数据采集 存储 Java
高德地图爬虫实践:Java多线程并发处理策略
高德地图爬虫实践:Java多线程并发处理策略
|
8天前
|
Java
并发编程之线程池的底层原理的详细解析
并发编程之线程池的底层原理的详细解析
45 0
|
8天前
|
Java
并发编程之线程池的应用以及一些小细节的详细解析
并发编程之线程池的应用以及一些小细节的详细解析
17 0
|
3天前
|
SQL 开发框架 .NET
高级主题:Visual Basic 中的多线程和并发编程
【4月更文挑战第27天】本文深入探讨了Visual Basic中的多线程和并发编程,阐述了其基本概念,如何使用`System.Threading.Thread`类创建线程,以及借助`ThreadPool`、`Monitor`和`SyncLock`进行同步管理。文章还提到了多线程编程面临的挑战如竞态条件、死锁和资源竞争,并介绍了VB的异步编程、TPL和并发集合等高级技术。通过实例展示了多线程在文件处理、网络通信和图像处理中的应用,并给出了多线程编程的最佳实践。总之,理解并掌握VB的多线程和并发编程能有效提升应用程序的性能和响应能力。
|
5天前
|
安全 Java
利用AQS(AbstractQueuedSynchronizer)实现一个线程同步器
利用AQS(AbstractQueuedSynchronizer)实现一个线程同步器
|
7天前
|
监控 测试技术 Linux
线程死循环是并发编程中常见的问题之一
【4月更文挑战第24天】线程死循环是并发编程中常见的问题之一
14 1
|
7天前
|
监控 安全 Java
一文讲明白Java中线程与进程、并发与并行、同步与异步
一文讲明白Java中线程与进程、并发与并行、同步与异步
7 1
|
7天前
|
Java
Java中的并发编程:理解和应用线程池
【4月更文挑战第23天】在现代的Java应用程序中,性能和资源的有效利用已经成为了一个重要的考量因素。并发编程是提高应用程序性能的关键手段之一,而线程池则是实现高效并发的重要工具。本文将深入探讨Java中的线程池,包括其基本原理、优势、以及如何在实际开发中有效地使用线程池。我们将通过实例和代码片段,帮助读者理解线程池的概念,并学习如何在Java应用中合理地使用线程池。
|
8天前
|
监控 Java
并发编程之线程池的详细解析
并发编程之线程池的详细解析
10 0
|
1天前
|
监控 安全 Java
【多线程学习】深入探究阻塞队列与生产者消费者模型和线程池常见面试题
【多线程学习】深入探究阻塞队列与生产者消费者模型和线程池常见面试题

相关实验场景

更多