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中文网其他相关文章！
