1. 首頁 > 生活百科 > >

golang中的鎖競爭問題( 二 )

生活百科

這是因為 ， 在map內部，是hmap結構，主要包含元數據（例如，計數器）和引用數據桶的指針 。因此，online := u.online 不會復制實際數據，而是復制的指針 ， 實際操作的還是同一片內存 。
解決這個問題也不難：

  • 我們可以把鎖的范圍擴大，像下面這樣：
    func (u *User) AllOnline() int { u.mu.RLock() defer u.mu.RUnlock() online := u.online sum := 0 for _, o := range online {if o {sum++} } return sum}
  • 另一種方法就是復制一個副本出來，像上面我們說的切片一樣：
    func (u *User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}
上面的例子中我們使用了*User定義了2個方法：
func (u *User) AddOnline(id string) { u.mu.Lock() u.online[id] = true u.mu.Unlock()}func (u *User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}我現在我們稍微修改下上面的列子：
package mainimport ( "strconv" "sync" "time")type User struct { musync.RWMutex online map[string]bool}func (u User) AddOnline(id string) { u.mu.Lock() u.online[id] = true u.mu.Unlock()}func (u User) AllOnline() int { u.mu.RLock() online := make(map[string]bool, len(u.online)) for s, b := range u.online {online[s] = b } u.mu.RUnlock() sum := 0 for _, o := range online {if o {sum++} } return sum}func main() { u := User{} u.online = make(map[string]bool) go func() {for i := 0; i < 10000; i++ {u.AddOnline("userid" + strconv.Itoa(i))} }() go func() {for i := 0; i < 10000; i++ {u.AllOnline()} }() time.Sleep(time.Second)}現在我們直接使用User結構體定義這兩個方法，但是當我們執行程序的時候，報了數據競爭的錯誤：
gorun -race 10.go==================WARNING: DATA RACERead at 0x00c00011e060 by goroutine 7:main.User.AllOnline()這個又是什么原因造成的呢？這是因為，當我門使用User作為參數時，直接復制了User的副本，因此sync.RWMutex也會被復制 。
因為鎖被復制了，所以對于同一個臨界資源，處于不同鎖的讀寫操作可以同時訪問 。
【golang中的鎖競爭問題】

推薦閱讀