sync.mutex 锁不起作用的困扰
使用 sync.mutex 和 sync.wtgroup 来控制共享数据的场景中,不少开发者可能遇到过锁不起作用的情况,导致最终结果令人困惑。
近期,一位初学者在使用这两个库时遇到了类似的难题。他们精心编写了一段代码,旨在利用锁和等待组来保证多个协程安全地对共享变量进行操作。然而,出人意料的是,最终结果却是随机的,与预期中的 1000 相距甚远。
代码中,共享变量 a 的递增操作被包裹在 sync.mutex 锁中,以确保同一时刻只有一个协程对 a 进行修改。但在问题中,var locker sync.mutex 的声明被放置在 for 循环内部。这种写法会导致每个协程都有自己的锁实例,而无法共享锁,从而无法实现锁的预期行为。
解决之道
为了解决这个问题,可以将 var locker sync.mutex 的声明移动到 for 循环外部,以创建单个共享锁实例。以下两种方式可以解决问题:
方式 1:
var locker sync.mutex for i := 0; i < 1000; i++ { wg.add(1) go func() { defer wg.done() locker.lock() defer locker.unlock() a++ fmt.println("a 的值为:", a) }() }
登录后复制
方式 2:
import "sync/atomic" // ... func hasLockAndWait() { var a int64 for i := 0; i < 1000; i++ { wg.Add(1) go func() { defer wg.Done() atomic.AddInt64(&a, 1) fmt.Println("a 的值为:", a) }() } // ... }
登录后复制
以上就是为什么 sync.Mutex 锁在我的并发程序中不起作用?的详细内容,更多请关注php中文网其它相关文章!