从不同的线程读取值

Question

我在Go中编写了很多并行计算软件.我想从工作线程收集数据,我不确定如何以安全的方式做到这一点.我知道,我可以用通道,但在我的情况,他们使之更加复杂,因为我必须在主线程同步莫名其妙消息(等到每个线程发送的东西).

脚本

主线程创建n个 Worker实例并work()在goroutine中启动它们的方法,以便每个工作者都在自己的线程中运行.每10秒,主线程应从工作者处收集一些简单值(例如迭代计数)并打印统一统计量.

题

从工人那里读取价值是否安全？主线程只读取值,每个单独的线程将写入自己的值.如果读取时值为几纳秒就可以了.

关于如何以简单的方式实现这一点的任何其他想法？

Answer 1

在Go中,如果至少有一个访问是写入,则没有同步的多个goroutine的并发访问值是安全的.您的案例符合列出的条件,因此您必须使用某种同步,否则行为将是未定义的.

如果goroutine想要将值发送给另一个,则使用通道.您的情况并非如此:您不希望您的工作人员每10秒发送一次更新,您希望主goroutine 每10秒获取一次状态.

所以在这个例子中,我只是用以下内容保护数据sync.RWMutex:当工作者想要修改这些数据时,他们必须获得写锁定.当主goroutine想要读取此数据时,它必须获取读锁定.

一个简单的实现可能如下所示:

type Worker struct {
    iter    int
    iterMux sync.RWMutex
}

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

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

func (w *Worker) incIter() {
    w.iterMux.Lock()
    w.iter++
    w.iterMux.Unlock()
}

使用此示例Worker,主goroutine可以使用获取迭代Worker.Iter(),并且工作程序本身可以使用Worker.setIter()或随时更改/更新迭代Worker.incIter(),而无需任何其他同步.通过正确使用来确保同步Worker.iterMux.

或者对于迭代计数器,您也可以使用该sync/atomic包.如果选择此选项,则只能使用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)
}

func (w *Worker) incIter() {
    atomic.AddInt64(&w.iter, 1)
}