在多个 goroutine 中同时修改字符串值是否需要使用互斥锁？

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《在多个 goroutine 中同时修改字符串值是否需要使用互斥锁？》，主要介绍了，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

在这种情况下我需要互斥体吗？我正在用一个 goroutine 刷新令牌，该令牌在另一个 goroutine 中使用。换句话说，我的令牌是否会在某个时刻为空，以便响应将是 401？

如果是，它是结构 c *threatq 的一部分还是一个简单的变量，我的意思是，我的代码中的一个“独立”变量。

// IndicatorChannelIterator returns indicators from ThreatQ into a channel.
func (c *threatq) IndicatorChannelIterator() (<-chan *models.Indicator, error) {
    // Authenticate
    token, err := c.authenticate(c.clientID, c.email, c.password)
    if err != nil {
        return nil, fmt.Errorf("Error while authenticating to TQ : %s", err)
    }

    // Periodically refresh the token
    ticker := time.NewTicker(30 * time.Minute)
    go func() {
        for range ticker.C {
            token, err = c.authenticate(c.clientID, c.email, c.password)
            if err != nil {
                logrus.Errorf("Error while authenticating to TQ : %s", err)
            }
        }
    }()

    // Prepare the query
    query := &Query{}

    // Get the first page
    firstTQResponse, err := c.advancedSearch(query, token, 0)
    if err != nil {
        return nil, fmt.Errorf("Error while getting the first page from TQ : %s", err)
    }

    // Create the channel
    indicators := make(chan *models.Indicator)

    // Request the others
    go func() {
        req := 1
        total := firstTQResponse.Total
        for offset := 0; offset < total; offset += c.perPage {    
            // Search the indicators
            tqResponse, err := c.advancedSearch(query, token, offset)
            if err != nil {
                logrus.Errorf("Error while getting the indicators from TQ : %s", err)
                continue
            }

...

解决方案

规则很简单：如果从多个 goroutine 访问一个变量，并且至少其中一个是写入，则需要显式同步。

您的情况确实如此：您的一个 goroutine 写入 token 变量（还有 err 变量！），另一个 goroutine 读取它，因此您必须同步访问。

由于 token 不是 threatq 结构的字段，因此放置保护它的互斥锁并不明智。始终将互斥锁放置在它应该保护的数据附近。

一些注意事项：如前所述，您还可以从多个 goroutine 中写入和读取本地 err 变量。你不应该这样做，而是创建另一个局部变量来保存来自其他 goroutine 的错误（除非你想在 goroutine 之间“转移”错误，但这里不是这种情况）。

查看相关问题：

Immutability of string and concurrency

Should we synchronize variable assignment in goroutine?

golang struct concurrent read and write without Lock is also running ok?

Reading values from a different thread

Why does this code cause data race?

是的，您也可以尝试在启用 -race 标志的情况下运行此测试。 Go 的竞争检测器可能会告诉你 token 是多个 goroutine 之间的共享变量。因此，必须使用 Mutex 或 RWMutex 对其进行保护。

就你的情况而言，我认为 RWMutex 更合适，因为有一个 goroutine 每 30 分钟更改（即写入） token 的状态，另一个 goroutine 读取其值。

如果不使用锁保护共享变量，第二个 goroutine 可能会读取 token 的旧值，该值可能已过期。

今天关于《在多个 goroutine 中同时修改字符串值是否需要使用互斥锁？》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！