sync

特性

安装

go get github.com/nilorg/sync

快速开始

import (
    "context"
    "github.com/go-redis/redis/v8"
    "github.com/nilorg/sync"
)

func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
    })
    rs := sync.NewRedisSync(rdb)
    m := rs.NewMutex("my_key")
    // 普通加锁
    if err := m.Lock(); err != nil {
        // 处理加锁失败
    }
    // 解锁
    _ = m.Unlock()

    // 阻塞等待加锁
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()
    if err := m.LockWait(ctx); err != nil {
        // 处理超时或取消
    }
    _ = m.Unlock()
}

接口说明

Mutexer

type Mutexer interface {
    Lock() error
    Unlock() error
}

WaitableMutexer

type WaitableMutexer interface {
    Mutexer
    LockWait(ctx context.Context) error // 阻塞直到加锁成功或上下文取消
}

测试

go test -v

License