超时时间改为10分钟
This commit is contained in:
@@ -19,7 +19,7 @@ type globalLock struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func NewGlobalLock(ctx context.Context, red *redis.Client, uniqueKey string) *globalLock {
|
func NewGlobalLock(ctx context.Context, red *redis.Client, uniqueKey string) *globalLock {
|
||||||
ctx, cancel := context.WithTimeout(ctx, time.Second*30)
|
ctx, cancel := context.WithTimeout(ctx, time.Minute*10)
|
||||||
return &globalLock{
|
return &globalLock{
|
||||||
redis: red,
|
redis: red,
|
||||||
ctx: ctx,
|
ctx: ctx,
|
||||||
@@ -82,7 +82,7 @@ func (g *globalLock) Unlock() bool {
|
|||||||
log.Println("globalLock Unlock", resp, err, g.uniqueKey, g.value)
|
log.Println("globalLock Unlock", resp, err, g.uniqueKey, g.value)
|
||||||
}
|
}
|
||||||
g.cancel()
|
g.cancel()
|
||||||
return false
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
// 刷新锁
|
// 刷新锁
|
||||||
|
|||||||
Reference in New Issue
Block a user