Semaphore自白:限流器用我就对了!(4)

简介: Semaphore自白:限流器用我就对了!(4)

其他补充


我还提供了一些其他方法,用于实现更多的功能,详情如下:


  • int availablePermits():返回此信号量中当前可用的许可证数。
  • int getQueueLength():返回正在等待获取许可证的线程数。
  • boolean hasQueuedThreads():是否有线程正在等待获取许可证。
  • boolean isFair():查询 Semaphore 使用的是公平模式还是非公平模式,如果此信号量使用的是公平模式则返回 true。
  • void release(int permits):释放给定数量的许可证,将其返回到信号量。
  • tryAcquire():从这个信号量获得许可证,只有在调用时可以使用该许可证。
  • tryAcquire(int permits):从这个信号量获取给定数量的许可证,只有在调用时全部可用。
  • tryAcquire(int permits, long timeout, TimeUnit unit):从该信号量获取给定数量的许可证,如果在给定的等待时间内全部可用,并且当前线程尚未 interrupted。
  • tryAcquire(long timeout, TimeUnit unit):如果在给定的等待时间内可用,并且当前线程尚未 到达 interrupted,则从该信号量获取许可。
  • void reducePermits(int reduction) :减少可用的许可证数量 reduction 个,它是 protected 方法。
  • Collection getQueuedThreads() :返回所有等待获取许可证的线程集合,它是 protected 方法。

总结


Semaphore 信号量是用来管理一组证书的,默认情况下它采取的是非公平的方式来管理证书,这样做的目的是为了实现高性能。Semaphore 中包含了两个重要的方法:


release() 方法发布一个许可证书;acquire() 方法阻塞并等待一个证书。当线程调用了 acquire() 方法只有拥有了证书才能继续执行,因此可以使用 Semaphore 来实现限流。

相关文章
|
5月前
|
Java 测试技术
Java多线程实战-从零手搓一个简易线程池(二)线程池实现与拒绝策略接口定义
Java多线程实战-从零手搓一个简易线程池(二)线程池实现与拒绝策略接口定义
|
5月前
|
安全 Java 开发工具
Semaphore:实现一个限流器
Semaphore:实现一个限流器
53 0
每日一博 - Semaphore使用场景分析以及源码分析
每日一博 - Semaphore使用场景分析以及源码分析
68 0
【AQS我可以讲十分钟】
【AQS我可以讲十分钟】
130 0
【AQS我可以讲十分钟】
深入理解JUC:第六章:Semaphore信号灯
深入理解JUC:第六章:Semaphore信号灯
深入理解JUC:第六章:Semaphore信号灯
|
存储 缓存 Java
JAVA多线程 | 实现用户任务排队 | 预估排队时长
JAVA多线程 | 实现用户任务排队 | 预估排队时长
369 0
JAVA多线程 | 实现用户任务排队 | 预估排队时长
|
存储 缓存 Java
线程池之刨根问底
线程池之刨根问底
116 0
线程池之刨根问底
我靠!Semaphore里面居然有这么一个大坑! (3)
我靠!Semaphore里面居然有这么一个大坑! (3)
261 0
我靠!Semaphore里面居然有这么一个大坑! (3)
抢红包算法(公平版和手速版)
抢红包有两种算法:二倍均值法(公平版)和线段切割法(手速版)
抢红包算法(公平版和手速版)
|
缓存 安全
深夜!小胖问我什么是读写锁?插队策略?升降级?(下)
深夜!小胖问我什么是读写锁?插队策略?升降级?
深夜!小胖问我什么是读写锁?插队策略?升降级?(下)