带有 CRUD 操作的 RW 锁

从现在开始，努力学习吧！本文《带有 CRUD 操作的 RW 锁》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

我不确定我的做法是否正确，这个想法是在读取时具有并发性，但仅在写入、更新或删除时才锁定。

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]
}

添加更多方法。

解决方案

代码不会由 goroutine 执行，而是在有大量并发请求的服务器上使用

如果它们是并发的，则它们位于 goroutine 中 - 例如，如果您使用 net/http 服务器，则每个请求都位于其自己的 goroutine 中。没有其他并发机制，因此如果您有并发性，那么您正在使用 goroutine，即使您的代码没有显式启动它们。

你不能“仅在addfoo和removefoo方法中阻塞”；这不是同步的工作原理。如果共享数据，则必须获取读取锁，并且如果某些读取与写入同时发生，则您将阻塞这些读取。如果您没有获取读取锁，则会出现竞争条件。

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

另一种方法是通过通信来共享内存。这是一个更复杂的重构，根据您的具体需求，有多种方法可以实现；我无法基于“foo”类型的通用示例提供解决方案。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~