数据竞争：Mutex下的地图破坏

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《数据竞争：Mutex下的地图破坏》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

在一个项目中，我想使用缓存来存储哈希之类的东西。但是，缓存中存储的值有时会更改为键。通常，密钥中的 4 个字符左右会被接管：

<- set hash::helloworldtest = abcdef0123456789
-> get hash::helloworldtest = testef0123456789

这大致就是我的缓存的结构：

type node struct {
    expires nodeExpiration
    value   interface{}
}

// ...

func (c *Cache) Set(key string, value interface{}, expiration time.Duration) {
    c.mu.Lock()
    c.val[key] = &node{
        expires: c.expiration(expiration),
        value:   value,
    }
    // fmt.Println( ... )
    c.mu.Unlock()
}

func (c *Cache) Get(key string) (interface{}, bool) {
    c.mu.Lock()
    if v, o := c.val[key]; o && v != nil {
        if !v.expires.IsExpired() {
            // fmt.Println( ... )
            c.mu.Unlock()
            return v.value, true
        }
    }
    c.mu.Unlock()
    return nil, false
}

// Cache Backend
func (b *CacheBackend) GetHash(key string) (res string, err error) {
    return b.get("hash::" + key)
}
func (b *CacheBackend) get(key string) (res string, err error) {
    if v, ok := b.cache.Get(key); ok {
        if s, ok := v.(string); ok {
            return s, nil
        }
        return "", b.errCast
    }
    return "", nil
}

// go-fiber Route
func (s *WebServer) handleGetHashAnywhere(ctx *fiber.Ctx) (err error) {
    path := ctx.Params("anywhere")
    var res string
    if res, err = s.Backend.GetHash(path); err != nil {
        return
    }
    if res == "" {
        ctx.Status(404)
    } else {
        ctx.Status(200)
    }
    return ctx.SendString(res)
}

我之前使用的是 sync.rwmutex，但将其替换为 sync.mutex，认为这可能是问题所在。但与 sync.mutex 相同。

go-fiber 在 goroutine 中调用 get 和 set 方法，然后返回这些值。

有谁知道这样的事情怎么会发生吗？

编辑 1：保存 []byte 而不是 string 效果很好。

正确答案

感谢@majodev，问题终于得到正确解决。

Zero Allocation 下的文档中描述了该问题。摘录：

由于 fiber 针对高性能进行了优化，因此从 fiber.ctx 返回的值默认情况下不是不可变的，并且将跨请求重用。 [...] 一旦您从处理程序返回，您从上下文中获取的任何值都将在未来的请求中重复使用，并且将在您的脚下发生变化。

因此必须复制上下文值，或者必须在 fiber 配置中传递“不可变”标志。

第一个解决方案：
从读取值创建新缓冲区并复制其内容

buf := bytes.newbufferstring(ctx.params("hash"))
hash := string(buf.bytes())

第二个解决方案：
使用内置函数 utils#copystring(string) 描述 here。

hash := utils.copystring(ctx.params("hash"))

第三种解决方案：
不可变的 config 标志

cfg := &fiber.Config{Immutable: true}

然后一切正常。

终于介绍完啦！小伙伴们，这篇关于《数据竞争：Mutex下的地图破坏》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！