golang一个常见的锁问题及解决

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package utility

import (
	"fmt"
	"sync"
	"sync/atomic"
)

type LockObj struct {
	Lock *sync.Mutex
	Num  int64
}

type KeyLock struct {
	globalLock sync.RWMutex
	locks      map[interface{}]*LockObj
}

func (l *KeyLock) getLock(key interface{}) *sync.Mutex {
	l.globalLock.RLock()
	if lockObj, ok := l.locks[key]; ok {
		atomic.AddInt64(&lockObj.Num, 1)
		l.globalLock.RUnlock()
		return lockObj.Lock
	}
	l.globalLock.RUnlock()

	// 如果不存在该锁，则加写锁并创建一个新的
	l.globalLock.Lock()
	defer l.globalLock.Unlock()

	// 双重检查，确保在加写锁后没有其他 goroutine 创建锁
	if lockObj, ok := l.locks[key]; ok {
		atomic.AddInt64(&lockObj.Num, 1)
		return lockObj.Lock
	}

	lockObj := &LockObj{
		Lock: &sync.Mutex{},
		Num:  1,
	}
	l.locks[key] = lockObj
	return lockObj.Lock
}

func (l *KeyLock) Lock(key interface{}) {
	l.getLock(key).Lock()
	fmt.Println("获取锁成功， areaId = ", key)
}

func (l *KeyLock) Unlock(key interface{}) {
    l.globalLock.Lock()
    lockObj, ok := l.locks[key]
    if !ok {
        l.globalLock.Unlock()
        fmt.Println("Unlock 失败，未找到锁，areaId =", key)
        return
    }

    lockObj.Lock.Unlock()
    fmt.Println("Unlock 释放锁成功，areaId =", key)

    if atomic.AddInt64(&lockObj.Num, -1) == 0 {
        delete(l.locks, key)
    }
    l.globalLock.Unlock()
}

func NewKeyLock() *KeyLock {
	return &KeyLock{
		locks: make(map[interface{}]*LockObj),
	}
}