在不同的 goroutine 中替换字符串的值时是否需要互斥量？

Question

在这种情况下我需要互斥量吗？我正在用一个 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            }...

Answer 1

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

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

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

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

Answer 2

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

在您的情况下，我认为这RWMutex更合适，因为有一个 goroutinetoken每 30 分钟更改（即写入）状态，而另一个 goroutine 读取其值。

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