RW锁定CRUD操作

Question

我不确定我是否接近这个权利，其想法是在阅读时保持并发性，但只有在写入或更新或删除时才会锁定。

type Data struct {
    sync.RWMutex
    fooMap map[string]Foo
}

func (d *Data) AddFoo(foo Foo) {
    d.Lock()
    defer d.Unlock()

    d.fooMap[foo.getName()] = foo
}

func (d *Data) GetFoo(name string) Foo {
    return d.fooMap[name]
}

func (d *Data) RemoveFoo(name string) Foo {
    d.Lock()
    defer d.Unlock()

    var foo = self.fooMap[name]
    if foo != nil {
        delete(d.fooMap, name)
    }
    return foo
}

func (d *Data) HasFoo(name string) bool {
    return d.fooMap[name] != nil
}

寻找一种有效的方法，当我从字典中读取时，我不会阻止，但只能在AddFoo和RemoveFoo方法中阻止。

编辑上下文略有不同，代码不会被goroutines执行，但会在我有大量并发请求的服务器上使用。

编辑2如果有两张地图

type Data struct {
    sync.RWMutex
    BarMutex sync.RWMutex{}
    fooMap map[string]Foo
    barMap map[string]Bar
}

// for Foo
func (d *Data) AddFoo(foo Foo) {
    d.Lock()
    defer d.Unlock()

    d.fooMap[foo.getName()] = foo
}

func (d *Data) GetFoo(name string) Foo {
    return d.fooMap[name]
}

// for Bar
func (d *Data) AddBar(bar Bar) {
    d.BarMutex.Lock()
    defer d.BarMutex.Unlock()

    d.barMap[bar.getName()] = bar
}

func (d *Data) GetBar(name string) Bar {
    d.BarMutex.RLock()
    defer d.BarMutex.RUnlock();
    return d.barMap[name]
}

添加更多方法。

Answer 1

代码不会被goroutines执行，但会在我有大量并发请求的服务器上使用

如果它们是并发的，它们就是goroutines - 例如，如果你使用的是net/http服务器，那么每个请求都在它自己的goroutine中。没有其他并发机制，所以如果你有并发性，你就会使用goroutine，即使你的代码没有明确地启动它们。

你不能“只在AddFoo和RemoveFoo方法中阻止”;这不是同步的工作原理。如果共享数据，则必须获取读取锁定，如果它们同时发生在写入中，您将阻止某些读取。如果您没有获取读取锁定，则表示您处于竞争状态。

func (d *Data) GetFoo(name string) Foo {
    d.RLock()
    d.RUnlock()
    return d.fooMap[name]
}

另一种方法是通过沟通来分享记忆。这是一个更复杂的重构，根据您的具体需求，有很多方法可以实现;基于“Foo”类型的通用示例，我不能提供解决方案。