Sync Map 使用可能会增加 ram 和 goroutine 的负担

本篇文章向大家介绍《Sync Map 使用可能会增加 ram 和 goroutine 的负担》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

您好，这是我将 util 称为收集器的代码

import (
    "context"
    "errors"
    "sync"
    "time"
)

type Collector struct {
    keyValMap *sync.Map
}

func (c *Collector) LoadOrWait(key any) (retValue any, availability int, err error) {
    value, status := c.getStatusAndValue(key)

    switch status {
    case 0:
        return nil, 0, nil
    case 1:
        return value, 1, nil
    case 2:
        ctxWithTimeout, _ := context.WithTimeout(context.Background(), 5 * time.Second)
        for {
            select {
            case <-ctxWithTimeout.Done():
                return nil, 0, errRequestTimeout
            default:
                value, resourceStatus := c.getStatusAndValue(key)
                if resourceStatus == 1 {
                    return value, 1, nil
                }
                time.Sleep(50 * time.Millisecond)
            }
        }
    }

    return nil, 0, errRequestTimeout
}

// Store ...
func (c *Collector) Store(key any, value any) {
    c.keyValMap.Store(key, value)
}

func (c *Collector) getStatusAndValue(key any) (retValue any, availability int) {
    var empty any
    result, loaded := c.keyValMap.LoadOrStore(key, empty)

    if loaded && result != empty {
        return result, 1
    }

    if loaded && result == empty {
        return empty, 2
    }

    return nil, 0
}

因此该实用程序的目的是充当缓存，其中相似的值仅加载一次但读取多次。然而，当 collector 的对象传递给多个 goroutine 时，只要多个 goroutine 尝试使用收集器缓存，我就会面临 gorotine 和 ram 使用量的增加。有人可以解释一下同步地图的这种用法是否正确。如果是，那么可能是什么原因导致 goroutine 数量多/内存使用率高

正确答案

当然，由于没有调用新创建的 ctxwithtimeout 上下文的取消函数，您可能会面临内存泄漏。为了解决这个问题，请将该行更改为：

ctxWithTimeout, cancelFunc := context.WithTimeout(context.Background(), requestTimeout)
defer cancelFunc()

因此，一旦上下文过期，您始终可以清除分配的所有资源。这应该可以解决泄漏问题。
关于 sync.map 的用法对我来说似乎很好。
如果这解决了您的问题或者还有其他问题需要解决，请告诉我，谢谢！

今天关于《Sync Map 使用可能会增加 ram 和 goroutine 的负担》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！