我是个新手,所以请温柔一点。所以我已经在我的一些代码中使用互斥体几周了。我理解其背后的概念:锁定对特定资源的访问,与其交互(读或写),然后再次为其他资源解锁。我使用的互斥体代码主要是复制粘贴调整。代码运行了,但我仍在尝试了解它的内部工作原理。到目前为止,我一直在结构中使用互斥体来锁定结构。今天我发现了这个例子,这让我完全不清楚互斥锁实际上锁定了什么。下面是一段示例代码:var state = make(map[int]int)var mutex = &sync.Mutex{}var readOps uint64var 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(),但我不确定情况是否如此。如果所有其他程序暂停一会儿,这听起来不像真正的多处理,所以我猜我对发生的事情没有很好的理解。有人可以帮助我理解计算机如何知道应该锁定哪些变量吗?
1 回答
慕田峪7331174
TA贡献1828条经验 获得超13个赞
锁定对特定资源的访问,与其交互(读或写),然后再次为其他资源解锁。
基本上是的。
让我困惑的是,互斥体和它应该锁定的值之间似乎没有任何联系。
互斥体只是一个互斥对象,用于同步对资源的访问。这意味着,如果两个不同的 goroutine 想要锁定互斥锁,则只有第一个 goroutine 可以访问它。第二个 goroutine 现在无限期地等待,直到它自己可以锁定互斥锁。与变量没有任何联系,您可以根据需要使用互斥体。例如只有一个http请求,只有一个数据库读/写操作或者只有一个变量赋值。虽然我不建议在这些示例中使用互斥体,但总体思路应该变得清晰。
但看看这段代码,它似乎以某种方式锁定整个程序,只执行锁定下方的行,直到再次运行解锁。
不是整个程序,只有每个想要访问同一个互斥体的 goroutine 都会等待,直到它可以访问为止。
我想这意味着所有其他 goroutine 都会暂停一会儿,直到再次运行解锁。
不,他们不会停下来。它们执行直到想要访问同一个互斥体为止。
如果您想使用变量专门对互斥体进行分组,为什么不创建一个结构体呢?
- 1 回答
- 0 关注
- 93 浏览
添加回答
举报
0/150
提交
取消