关于java:Redisson-分布式锁源码-11Semaphore-和-CountDownLatch

前言

Redisson 除了提供了分布式锁之外，还额定提供了同步组件，Semaphore 和 CountDownLatch。

Semaphore

意思就是在分布式场景下，只有 3 个凭证，也就意味着同时只会有三个线程执行业务。

设置凭证

参数列表：

1. KEYS[1]：指定的 key 这里叫 semaphore
2. KEYS[2]：redisson_sc:{semaphore}
3. ARGV[1]：凭证数 3

这块 lua 脚本绝对简略，间接设置一个 key 的 value 为 3。

获取凭证

参数列表：

1. KEYS[1]：指定的 key 这里叫 semaphore
2. ARGV[1]：要获取的凭证数，默认 1

这段 lua 脚本就是：

1. 获取 key semaphore 的值
2. 如果值大于等于 1（要获取的凭证数），对值进行递加
3. 胜利返回 1，失败返回 0

如果胜利获取凭证，间接返回，没有获取到凭证，则自旋期待。

开释凭证

开释凭证间接对 Redis key 的值进行自增即可。

CountDownLatch

输入内容如下：

源码剖析

设置门闩数量

这块都大同小异。

缩小门闩数量

就是对这个值进行递加。

而 latch.await() 就是自旋获取门闩的值，直到为 0 了，而后持续往下执行。

总结

Redisson 实现分布式的 Semaphore 和 CountDownLatch 根本内容就是如此，仅仅通过在 Redis 保护一个公共的变量，而后进行原子更新即可。

相干举荐

• Redisson 分布式锁源码 10：读写锁
• Redisson 分布式锁源码 09：RedLock 红锁的故事
• Redisson 分布式锁源码 08：MultiLock 加锁与锁开释