我是个新手,所以请温柔一点。
所以我已经在我的一些代码中使用互斥体几周了。我理解其背后的概念:锁定对特定资源的访问,与其交互(读或写),然后再次为其他资源解锁。
我使用的互斥体代码主要是复制粘贴调整。代码运行了,但我仍在尝试了解它的内部工作原理。到目前为止,我一直在结构中使用互斥体来锁定结构。今天我发现了这个例子,这让我完全不清楚互斥锁实际上锁定了什么。下面是一段示例代码:
var state = make(map[int]int)
var mutex = &sync.Mutex{}
var readOps uint64
var writeOps uint64
// Here we start 100 goroutines to execute repeated reads against the state, once per millisecond in each goroutine.
for r := 0; r < 100; r++ {
go func() {
total := 0
for {
key := rand.Intn(5)
mutex.Lock()
total += state[key]
mutex.Unlock()
atomic.AddUint64(&readOps, 1)
time.Sleep(time.Millisecond)
}
}()
}
让我困惑的是,互斥体和它应该锁定的值之间似乎没有任何联系。直到今天,我还认为互斥锁可以锁定特定变量,但查看这段代码,似乎以某种方式锁定整个程序,只执行锁定下方的行,直到再次运行解锁。我想这意味着所有其他 goroutine 都会暂停一会儿,直到再次运行解锁。lock()由于代码已编译,我想它可以知道在和 之间访问哪些变量unlock(),但我不确定情况是否如此。
如果所有其他程序暂停一会儿,这听起来不像真正的多处理,所以我猜我对发生的事情没有很好的理解。
有人可以帮助我理解计算机如何知道应该锁定哪些变量吗?
慕田峪7331174
相关分类