如何安全地从并行 Go 例程读取共享数据？

并行 Go 例程中从共享数据中读取值

问题：

Go 中如何安全读取数据来自并行计算中的单独线程？具体来说，如何在不影响数据完整性的情况下从工作线程收集数据？

场景：

主线程创建多个异步运行的工作实例。每 10 秒，主线程需要从工作线程收集值（例如迭代计数）并显示综合报告。

问题：

安全吗直接读取worker的值？此外，是否有其他方法可以有效地实现此要求？

答案：

直接从worker读取值是不安全的，因为它违反了Go的并发模型。在 Go 中，goroutine 之间共享的数据必须通过同步机制进行保护，以防止同时写入操作导致数据损坏。

为了解决这个问题，一种方法是使用sync.RWMutex 数据结构：

• 写锁：worker修改共享数据时获得，保证独占
• 读锁：读取共享数据时由主线程获取，允许并发读，但阻止写。

使用sync.RWMutex的示例实现：

type Worker struct {
    iterMu sync.RWMutex
    iter   int
}

func (w *Worker) Iter() int {
    w.iterMu.RLock()
    defer w.iterMu.RUnlock()
    return w.iter
}

func (w *Worker) setIter(n int) {
    w.iterMu.Lock()
    w.iter = n
    w.iterMu.Unlock()
}

或者，sync/atomic 包提供原子操作，确保线程安全访问共享变量。使用sync/atomic的示例实现：

type Worker struct {
    iter int64
}

func (w *Worker) Iter() int64 {
    return atomic.LoadInt64(&w.iter)
}

func (w *Worker) setIter(n int64) {
    atomic.StoreInt64(&w.iter, n)
}

通过利用这些方法，这两种方法都提供了一个强大的解决方案，可以从单独的线程读取值，同时保持数据完整性。

以上是如何安全地从并行 Go 例程读取共享数据？的详细内容。更多信息请关注PHP中文网其他相关文章！