Documentation
¶
Overview ¶
Package lock 提供同步任务的并发控制原语:
- 跨实例互斥锁:oekit redisx/distlock(SetNX + Lua 原子解锁 + 自动续期), 本包只负责固定 key 前缀与客户端构造;
- Semaphore:基于 redis ZSET 的分布式信号量,限制全局并发上限, 实现复用 oekit redisx/distlock.Semaphore。
Index ¶
Constants ¶
View Source
const ( // LockKeyPrefix 是跨实例互斥锁的 key 前缀。distlock 以 "<prefix>:<key>" 落 key, // 与迁移前自写实现的 "git-sync:lock:<key>" 布局一致:滚动升级期间新老实例 // 看到的是同一把锁,不会出现两边各持一把而同时执行的窗口。 LockKeyPrefix = "git-sync:lock" // SemaphoreKeyPrefix 是全局并发信号量的 key 前缀。与迁移前自写实现的 // "git-sync:semaphore:<key>" 布局保持一致:滚动升级期间新老实例看到的是 // 同一把信号量,不会两把各算各的配额而使实际上限翻倍。 SemaphoreKeyPrefix = "git-sync:semaphore:" )
Variables ¶
This section is empty.
Functions ¶
func NewLocker ¶ added in v0.10.0
func NewLocker(client redis.UniversalClient, opts ...distlock.RedisLockerOption) *distlock.RedisLocker
NewLocker 构造跨实例互斥锁,key 前缀固定为 LockKeyPrefix;续期等策略由调用方按场景追加。
Types ¶
type RedisPoolOptions ¶
type RedisPoolOptions struct {
PoolSize int // 连接池大小,默认 10*GOMAXPROCS
MinIdleConns int // 最小空闲连接数,默认 0(冷启动无预热)
DialTimeoutSec int // 建连超时秒数,默认使用 OS TCP 超时
ReadTimeoutSec int // 读超时秒数
WriteTimeoutSec int // 写超时秒数
}
RedisPoolOptions 连接池可选配置,零值使用 go-redis 默认。
type Semaphore ¶
Semaphore 是全局并发上限的分布式信号量,实现复用 oekit redisx/distlock.Semaphore (ZSET 槽位模型 + 原子 Lua 脚本)。
本包只做两件事:固定 key 前缀、对外暴露 key 供测试与运维观测; 槽位的获取/续期/释放/清理语义全部跟随上游,不再自维护 Lua 脚本。
与迁移前自写实现的差异(均为上游更严的方向):
- Acquire 对同一 identifier 幂等刷新(重复 Acquire 不占第二个槽);
- Renew 只续期**未过期**的槽,已过期槽不得借 Renew 复活—— 它的配额可能已被其他 Acquire 接管,复活即超限;
- Release 幂等(未持有不报错),Cleanup 返回被清理的槽数。
func NewSemaphore ¶
func NewSemaphore(client redis.UniversalClient, key string, max int, slotTTL time.Duration) *Semaphore
NewSemaphore 构造分布式信号量,Redis key 为 "<SemaphoreKeyPrefix><key>"。 slotTTL 为单个槽的存活时长:持有者需周期性 Renew,进程崩溃后槽在 slotTTL 后自动释放。
Source Files
Click to show internal directories.
Click to hide internal directories.