应用开发

Redisson 分布式锁源码 11:Semaphore 和 CountDownLatch

时间:2010-12-5 17:23:32  作者:数据库   来源:IT科技  查看:  评论:0
内容摘要:前言Redisson 除了提供了分布式锁之外,还额外提供了同步组件,Semaphore 和 CountDownLatch。1、Semaphore意思就是在分布式场景下,只有 3 个凭证,也就意味着同时

前言

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

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

云服务器提供商
copyright © 2025 powered by 益强资讯全景  滇ICP备2023006006号-31sitemap