Что вызывает эту гонку данных? - PullRequest
Новая
       40

Что вызывает эту гонку данных?

0 голосов
/ 08 января 2019

Почему этот код вызывает гонку данных? Я уже использовал Atomic Add. 

package main

import (
    "sync/atomic"
    "time"
)

var a int64

func main() {
    for {
        if a < 100 {
            atomic.AddInt64(&a, 1)
            go run()
        }
    }
}

func run() {
    <-time.After(5 * time.Second)
    atomic.AddInt64(&a, -1)
}

Я запускаю команду go run --race с этим кодом и получаю: 

==================
WARNING: DATA RACE
Write at 0x000001150f30 by goroutine 8:
  sync/atomic.AddInt64()
      /usr/local/Cellar/go/1.11.2/libexec/src/runtime/race_amd64.s:276 +0xb
  main.run()
      /Users/flask/test.go:22 +0x6d

Previous read at 0x000001150f30 by main goroutine:
  main.main()
      /Users/flask/test.go:12 +0x3a

Goroutine 8 (running) created at:
  main.main()
      /Users/flask/test.go:15 +0x75
==================

Не могли бы вы помочь мне объяснить это? И как исправить это предупреждение? Спасибо!

1 Ответ

0 голосов
/ 08 января 2019

Вы не использовали пакет atomic в всех местах, где вы получили доступ к переменной. Весь доступ должен быть синхронизирован с переменными, к которым обращаются из нескольких групп одновременно, включая reads : 

for {
    if value := atomic.LoadInt64(&a); value < 100 {
        atomic.AddInt64(&a, 1)
        go run()
    }
}

С этим изменением состояние гонки исчезает.

Если вы просто хотите проверить значение, вам даже не нужно сохранять его в переменной, так что вы можете просто сделать: 

for {
    if atomic.LoadInt64(&a) < 100 {
        atomic.AddInt64(&a, 1)
        go run()
    }
}
...