我不知道為什么在使用互斥鎖時工作。c <- i因為在函數的第一行有。rwMutex.Lock()second()如果在通道中不起作用，則無法理解以下輸出值。輸出值按 1 的順序排列。mutex執行go second(...)執行rwMutex.Lock()所以不要運行，因為寫入被鎖定！c <- i但正在工作。num := <-cmain.govar ( dataSendChannel = make(chan int) rwMutex = new(sync.RWMutex))func main() { go first(dataSendChannel) time.Sleep(time.Second * 100)}func first(c chan<- int) { for i := 1; i <= 10; i++ { go second(dataSendChannel) c <- i }}func second(c <-chan int) { rwMutex.Lock() num := <-c time.Sleep(time.Duration(10-num) * time.Second) fmt.Println("[NUM] : ", num) rwMutex.Unlock()}輸出[NUM] : 1[NUM] : 2[NUM] : 3[NUM] : 4[NUM] : 5[NUM] : 6[NUM] : 7[NUM] : 8[NUM] : 9[NUM] : 10這是不使用 時的輸出值。mutexmain.gofunc second(c <-chan int) { num := <-c time.Sleep(time.Duration(10-num) * time.Second) fmt.Println("[NUM] : ", num)}輸出[NUM] : 10[NUM] : 9[NUM] : 8[NUM] : 7[NUM] : 6[NUM] : 5[NUM] : 4[NUM] : 3[NUM] : 2[NUM] : 1在通道上接收到一個數據后，互斥鎖是否有效？
1 回答
德瑪西亞99
TA貢獻1770條經驗 獲得超3個贊
使用互斥鎖鎖定變量時，將阻止后續的 goroutine 鎖定互斥體，因為它尚未解鎖。num
因此，第二個goroutine實際上等到第一個完成睡眠（9秒），然后打印數字1。只有在那一刻，第二個 goroutine 可以鎖定互斥體并寫入變量 ，但第三個 goroutine 還不能訪問，所以它再次等待，直到第二個 goroutine 打印數字，依此類推。num
沒有互斥體，第一個goroutine的睡眠時間最長，它不會阻止其他人執行和寫入，所以它打印了最新的，其他人可以先完成他們的工作，因為睡眠時間更短，完成得更快。num
如果刪除睡眠狀態，則兩種情況下的工作方式相同。
package main
import (
"fmt"
"sync"
"time"
)
var (
dataSendChannel = make(chan int)
rwMutex = new(sync.RWMutex)
)
func main() {
go first(dataSendChannel)
time.Sleep(time.Second * 100)
}
func first(c chan<- int) {
for i := 1; i <= 10; i++ {
go second(dataSendChannel)
c <- i
}
}
func second(c <-chan int) {
rwMutex.Lock()
num := <-c
fmt.Println("[NUM] : ", num)
rwMutex.Unlock()
}
- 1 回答
- 0 關注
- 113 瀏覽
添加回答
舉報
0/150
提交
取消