新手初学redis,尝试redis锁的时候,go代码如下:
func main() {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
})
for i := 0; i < 100; i++ {
go func() {
for {
//一直 for 循环抢锁吗?
ok, err := client.SetNX("sync", true, time.Second*5).Result()
if err == nil && ok {
res, err := client.Get("num").Result()
fmt.Printf("num : %s\n", res)
num, err := strconv.Atoi(res)
err = client.Set("num", num+1, 0).Err()
_, err = client.Del("sync").Result()
if err != nil {
log.Println(err)
}
break
}
//time.Sleep(time.Millisecond * 10)
}
}()
}
time.Sleep(time.Second * 20)
}
代码中我开了 100 个协程抢锁,操作一个数据.
我的疑问是,当一个协程抢到了这个 sync 锁,那么其他的 99 个协程, 都一直在不停的在一个循环中重复抢锁吗?这样子是否会对redis产生大量的无意义的请求...网上搜了一下相关的实现demo代码,发现都是类似的
while(true)
{
// xxxxxxx
}
进行抢锁....所以很疑惑,若是真实生产环境也是这样实现嘛....还是我一开始就错了...如果有相关资料或者是搜索关键词,还望大佬指点一二.
慕虎7371278
FFIVE
蝴蝶刀刀
相关分类