如何安全地从多个 Go 线程收集数据，同时防止竞争条件？

Go 中多线程的安全数据收集

在没有适当同步的情况下跨多个线程并发访问共享数据可能会导致 Go 中出现未定义的行为。这对于涉及读写操作的场景尤其重要。

并发访问风险

在您的情况下，多个工作线程并行运行，而主线程定期寻求从这些工人那里收集价值。如果不加以控制，可能会出现竞争条件，即多个线程尝试同时访问相同的数据，从而可能会损坏数据。

同步选项

为了防止并发访问问题，您需要采用同步机制。一种常用的方法是通道，它促进 goroutine 之间的安全数据交换。但是，就您而言，通道可能不是最有效的选择，因为您正在寻求从工作人员检索数据，而不是让他们主动发送数据。

互斥保护数据

更合适的解决方案涉及使用同步原语（例如sync.RWMutex）来保护共享数据结构。此锁确保一次只有一个线程可以修改数据，同时允许多个线程同时访问数据进行读取。

实现示例

这里是一个简化的实现，使用async.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()
}

在此示例中，worker 的 Iter 方法获取读锁并返回当前迭代计数。 setIter 方法获取写锁，更新迭代计数，然后释放锁。

或者，您可以使用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 中的多个线程收集数据，确保数据完整性并防止竞争条件。

以上是如何安全地从多个 Go 线程收集数据，同时防止竞争条件？的详细内容。更多信息请关注PHP中文网其他相关文章！