如何安全地读取 Go 中多个 Goroutine 的值？

在 Go 中从不同线程安全地读取值

在 Go 中，在没有适当同步的情况下从多个 goroutine 并发访问值是危险的。为了确保数据完整性，采用同步机制至关重要。

使用互斥锁和读/写锁进行同步

在给定场景中，主线程需要收集数据每 10 秒从工作线程获取一次值，通道是不够的。相反，可以使用读/写互斥锁。

工作线程在更新其值时将获取写锁，而主线程在检索值时将获取读锁。这可以防止竞争条件并保证数据一致性。

使用互斥体的示例实现

以下代码示例了使用互斥体的简单实现：

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 包提供线程安全的原子计数器，允许直接读写操作，而无需互斥体的开销。

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 中多个 Goroutine 的值？的详细内容。更多信息请关注PHP中文网其他相关文章！