Golang示例续期锁:Redis+Channel+sync.Mutex
2022/6/22 2:19:54
本文主要是介绍Golang示例续期锁:Redis+Channel+sync.Mutex,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
package main import ( "context" "fmt" "github.com/go-redis/redis" "golang.org/x/sync/errgroup" "log" "sync" "time" ) func main() { NewRedis() fu1() time.Sleep(100 * time.Second) } var rdb *redis.Client var ctx = context.Background() var mutex sync.Mutex func NewRedis() { rdb = redis.NewClient(&redis.Options{ Addr: "127.0.0.1:6379", Password: "", // no password set DB: 0, // use default DB }) } func Lock(key string) error { mutex.Lock() defer mutex.Unlock() _, err := rdb.SetNX(key, 1, 1*time.Second).Result() if err != nil { log.Println(err.Error()) } return err } func UnLock(key string) error { _, err := rdb.Del(key).Result() if err != nil { log.Println(err.Error()) return err } return err } func Expire(key string) error { _, err := rdb.Expire(key, 1*time.Second).Result() if err != nil { log.Println(err.Error()) return err } return err } func fu1() error { ch := make(chan bool) // 加锁 err := Lock("lock_key") if err != nil { return err } //解锁 defer func() { err = UnLock("lock_key") if err != nil { fmt.Println(err.Error()) return } fmt.Println("release redis lock success") }() g, _ := errgroup.WithContext(context.Background()) //...主业务代码 g.Go(func() error { time.Sleep(15 * time.Second) ch <- true return nil }) //锁续期 g.Go(func() error { ticker := time.NewTicker(time.Second * 1) for { select { // 任务还没执行完 每秒续期 case <-ticker.C: Expire("lock_key") fmt.Println(time.Now()) //收到执行完的 channel 就关闭time定时任务 case <-ch: ticker.Stop() return nil } } }) //等待信号量 if err = g.Wait(); err != nil { return err } close(ch) return nil }
这篇关于Golang示例续期锁:Redis+Channel+sync.Mutex的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-03-21redisinsight-v2
- 2024-02-26Typed property App\Api\Mapper\GamePropsConfigMapper::$apiRedis must not be accessed before initia-icode9专业技术文章分享
- 2024-02-21redisson getlock
- 2024-02-20redis config
- 2024-02-20redis leaderboard
- 2024-01-23缓存选型:Redis or MemCache
- 2024-01-22面试官:Redis持久化能关吗?怎么关?
- 2024-01-21Redis压测工具redis-benchmark-icode9专业技术文章分享
- 2024-01-19这才是你应该了解的Redis数据结构!
- 2024-01-18Redis系列:使用 Redis Module 扩展功能