mutex.Lock() 如何知道要锁定哪些变量?

我是个新手,所以请温柔一点。


所以我已经在我的一些代码中使用互斥体几周了。我理解其背后的概念:锁定对特定资源的访问,与其交互(读或写),然后再次为其他资源解锁。


我使用的互斥体代码主要是复制粘贴调整。代码运行了,但我仍在尝试了解它的内部工作原理。到目前为止,我一直在结构中使用互斥体来锁定结构。今天我发现了这个例子,这让我完全不清楚互斥锁实际上锁定了什么。下面是一段示例代码:


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(),但我不确定情况是否如此。


如果所有其他程序暂停一会儿,这听起来不像真正的多处理,所以我猜我对发生的事情没有很好的理解。


有人可以帮助我理解计算机如何知道应该锁定哪些变量吗?


qq_遁去的一_1
浏览 94回答 1
1回答

慕田峪7331174

锁定对特定资源的访问,与其交互(读或写),然后再次为其他资源解锁。基本上是的。让我困惑的是,互斥体和它应该锁定的值之间似乎没有任何联系。互斥体只是一个互斥对象,用于同步对资源的访问。这意味着,如果两个不同的 goroutine 想要锁定互斥锁,则只有第一个 goroutine 可以访问它。第二个 goroutine 现在无限期地等待,直到它自己可以锁定互斥锁。与变量没有任何联系,您可以根据需要使用互斥体。例如只有一个http请求,只有一个数据库读/写操作或者只有一个变量赋值。虽然我不建议在这些示例中使用互斥体,但总体思路应该变得清晰。但看看这段代码,它似乎以某种方式锁定整个程序,只执行锁定下方的行,直到再次运行解锁。不是整个程序,只有每个想要访问同一个互斥体的 goroutine 都会等待,直到它可以访问为止。我想这意味着所有其他 goroutine 都会暂停一会儿,直到再次运行解锁。不,他们不会停下来。它们执行直到想要访问同一个互斥体为止。如果您想使用变量专门对互斥体进行分组,为什么不创建一个结构体呢?
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Go