我们应该在 goroutine 中同步变量赋值吗？

Question

假设我声明了两个映射并希望将其分配到错误组中的两个不同的 goroutine 中。我不执行任何读/写。 我应该用lock 保护分配操作还是可以省略它？

UPD3：在Java Concurrency In PracticeBrian Goetz's Part I Chapter 3 Shared Objects，提到：

锁定不仅仅是互斥；也是记忆 能见度。确保所有线程都看到最新的值 共享可变变量，读写线程必须 在公共锁上同步。

var (
    mu     sync.Mutex
    one    map[string]struct{}
    two    map[string]struct{}
)
g, gctx := errgroup.WithContext(ctx)
g.Go(func() error {
    resp, err := invokeFirstService(gctx, request)
    if err != nil {
        return err
    }
    mu.Lock()
    one = resp.One
    mu.Unlock()
    return nil
})

g.Go(func() error {
    resp, err := invokeSecondService(gctx, request)
    if err != nil {
        return err
    }
    mu.Lock()
    two = resp.Two
    mu.Unlock()
    return nil
})
if err := g.Wait(); err != nil {
    return err
}
// UPD3: added lock and unlock section
m.Lock()
defer m.Unlock()
performAction(one, two)

UPD：添加了更多关于变量的上下文

UPD2：我的疑虑是什么：我们有 3 个 goroutine - 父级和错误组中的两个。不能保证我们的父 goroutine 共享内存在 errgroup goroutine 完成后获得最后一次更新，直到我们用内存屏障包装对共享内存的访问

Answer 1

Group.Wait() 阻塞，直到来自Group.Go() 方法的所有函数调用都返回，所以这是一个同步点。这可确保在完成对 one 和 two 的任何写入之前，performAction(one, two) 不会启动，因此在您的示例中，互斥锁是不必要的。

g, gctx := errgroup.WithContext(ctx)
g.Go(func() error {
    // ...
    one = resp.One
    return nil
})

g.Go(func() error {
    // ...
    two = resp.Two
    return nil
})

if err := g.Wait(); err != nil {
    return err
}
// Here you can access one and two safely:
performAction(one, two)

如果您要从其他 goroutine 访问 one 和 two 而编写它们的 goroutine 同时运行，那么是的，您需要锁定它们，例如：

// This goroutine runs concurrently, so all concurrent access must be synchronized:
go func() {
    mu.Lock()
    fmt.Println(one, two)
    mu.Unlock()
}()

g, gctx := errgroup.WithContext(ctx)
g.Go(func() error {
    // ...
    mu.Lock()
    one = resp.One
    mu.Unlock()
    return nil
})

g.Go(func() error {
    // ...
    mu.Lock()
    two = resp.Two
    mu.Unlock()
    return nil
})

if err := g.Wait(); err != nil {
    return err
}
// Note that you don't need to lock here
// if the first concurrent goroutine only reads one and two.
performAction(one, two)

还要注意，在上面的例子中你可以使用sync.RWMutex，在读取它们的goroutine中，RWMutex.RLock()和RWMutex.RUnlock()也足够了。

Answer 2

在这种情况下，只有一个 goroutine 可以访问地图。我认为你不需要锁。