4. Read Write Mutex Review
package main
import (
"fmt"
"sync"
)
func main() {
m := map[int]int{}
mu := &sync.RWMutex{}
go writeLoop(m, mu)
go readLoop(m, mu)
go readLoop(m, mu)
go readLoop(m, mu)
go readLoop(m, mu)
// stop program from exiting, must be killed
block := make(chan struct{})
<-block
}
func writeLoop(m map[int]int, mu *sync.RWMutex) {
for {
for i := 0; i < 100; i++ {
mu.Lock()
m[i] = i
mu.Unlock()
}
}
}
func readLoop(m map[int]int, mu *sync.RWMutex) {
for {
mu.RLock()
for k, v := range m {
fmt.Println(k, "-", v)
}
mu.RUnlock()
}
}