範囲の前にRLockマップする必要がありますか？

Question

複数のゴルーチンがnotifyAll funcを実行する場合、ロックなしでレンジマップを設定することは安全ですか？実際にある範囲では、時々マップからエントリを削除する必要があります。

var mu sync.RWMutex 

func (self *Server) notifyAll(event *Event) 
    ch := make(chan int, 64) 
    num := 0 
    for k, v := range self.connections { 
    num++ 
    ch <- num 

    go func(int k, conn *Conn) { 
     err := conn.sendMessage(event) 
     <-ch 
     if err != nil { 
     self.removeConn(k) 
     } 
    }(k, v) 
    } 
} 

func (self *Server) removeConn(int k) { 
    mu.Lock() 
    defer mu.Unlock() 
    delete(self.connections, k) 
} 

// Somewhere in another goroutine 
func (self *Server) addConn(conn *Conn, int k) { 
    mu.Lock() 
    defer mu.Unlock() 
    self.connections[k] = conn 
} 

範囲の前にRLockマップを作成する必要がありますか？

func (self *Server) notifyAll(event *Event) 
    mu.RLock() 
    defer mu.RUnlock() 
    // Skipped previous body... 
} 

Answer 1

あなたは同時がremoveConnでの書き込みとnotifyAllに読み込みを防止するためにマップをロックする必要があります。

Answer 2

短い答え：マップは並行安全ではありません（まだスレッドセーフと言えます）。

異なるジャンプルーチンからマップにアクセスする必要がある場合は、何らかの形式のアクセスオーケストレーションを使用する必要があります。そうしないと、「制御されていないマップアクセスによってプログラムがクラッシュする可能性があります」（this参照）。

編集：

これは別の実装である - ミューテックスをすべて一緒に無視し、より多くのGoishアプローチを使用しています（ハウスキーピングの懸念を考慮せずにタイムアウトを終了し、ログなど）（これは、単にこれを実証するためでありますアクセスオーケストレーションの懸念をクリアするために私たちを助けアプローチ - ）あなたのケースのために正しいかではないかもしれません。

type Server struct { 
    connections map[*Conn]struct{} 

    _removeConn, _addConn chan *Conn 
    _notifyAll   chan *Event 
} 

func NewServer() *Server { 
    s := new(Server) 
    s.connections = make(map[*Conn]struct{}) 
    s._addConn = make(chan *Conn) 
    s._removeConn = make(chan *Conn, 1) 
    s._notifyAll = make(chan *Event) 
    go s.agent() 
    return s 
} 

func (s *Server) agent() { 
    for { 
     select { 
     case c := <-s._addConn: 
      s.connections[c] = struct{}{} 
     case c := <-s._removeConn: 
      delete(s.connections, c) 
     case e := <-s._notifyAll: 
      for c := range s.connections { 
       closure := c 
       go func() { 
        err := closure.sendMessage(e) 
        if err != nil { 
         s._removeConn <- closure 
        } 
       }() 
      } 
     } 
    } 
} 

func (s *Server) removeConn(c *Conn) { 
    s._removeConn <- c 
} 

func (s *Server) addConn(c *Conn) { 
    s._addConn <- c 
} 

編集：

私は修正されました。 Damian Gryskiによると、マップは同時読み取りで安全です。マップ順序が各反復で変化する理由は、「マップ反復順序のために選択されたランダムシード」​​であり、これはゴルーチンの反復に対して局所的である（別のtweet）。この事実は、最初の編集と提案された解決策には影響しません。