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 维护一个公共的变量,然后进行原子更新即可。

本文转载自微信公众号「程序员小航」,可以通过以下二维码关注。转载本文请联系程序员小航公众号。

二维码

扫一扫,关注我们

声明:本文由【益华网络】编辑上传发布,转载此文章须经作者同意,并请附上出处【益华网络】及本页链接。如内容、图片有任何版权问题,请联系我们进行处理。

感兴趣吗?

欢迎联系我们,我们愿意为您解答任何有关网站疑难问题!

您身边的【网站建设专家】

搜索千万次不如咨询1次

主营项目:网站建设,手机网站,响应式网站,SEO优化,小程序开发,公众号系统,软件开发等

立即咨询 15368564009
在线客服
嘿,我来帮您!