Redisson 分布式锁源码 11:Semaphore 和 CountDown···
发布时间:2025-05-15 15:55:36
作者:益华网络
来源:undefined
浏览量(2)
点赞(3)
摘要:前言 Redisson 除了提供了分布式锁之外,还额外提供了同步组件,Semaphore 和 CountDownLatch。 1、Semaphore 意思就是在分布式场景下,只有 3 个凭证,也就意味着同时只会有三个线程执行业务。 设置凭证 参数列表: KEYS[1]:
前言
Redisson 除了提供了分布式锁之外,还额外提供了同步组件,Semaphore 和 CountDownLatch。
1、Semaphore
意思就是在分布式场景下,只有 3 个凭证,也就意味着同时只会有三个线程执行业务。
设置凭证
参数列表:
KEYS[1]:指定的 key 这里叫 semaphore KEYS[2]:redisson_sc:{semaphore} ARGV[1]:凭证数 3这块 lua 脚本相对简单,直接设置一个 key 的 value 为 3。
获取凭证
参数列表:
KEYS[1]:指定的 key 这里叫 semaphore ARGV[1]:要获取的凭证数,默认 1这段 lua 脚本就是:
获取 key semaphore 的值 如果值大于等于 1(要获取的凭证数),对值进行递减 成功返回 1,失败返回 0如果成功获取凭证,直接返回,没有获取到凭证,则自旋等待。
释放凭证
释放凭证直接对 Redis key 的值进行自增即可。
2、CountDownLatch
输出内容如下:
源码分析
设置门闩数量
这块都大同小异。
减少门闩数量
就是对这个值进行递减。
而 latch.await() 就是自旋获取门闩的值,直到为 0 了,然后继续往下执行。
3、总结
Redisson 实现分布式的 Semaphore 和 CountDownLatch 基本内容就是如此,仅仅通过在 Redis 维护一个公共的变量,然后进行原子更新即可。
本文转载自微信公众号「程序员小航」,可以通过以下二维码关注。转载本文请联系程序员小航公众号。
扫一扫,关注我们
声明:本文由【益华网络】编辑上传发布,转载此文章须经作者同意,并请附上出处【益华网络】及本页链接。如内容、图片有任何版权问题,请联系我们进行处理。
3