Почему в Printf в этом коде обнаружено состояние гонки Go - PullRequest
Новая
       27

Почему в Printf в этом коде обнаружено состояние гонки Go

3 голосов
/ 02 ноября 2019

Я написал некоторый простой код Go, чтобы понять условия гонки, как показано: 

package main

import (
    "fmt"
    "sync"
)

type outer struct {
    sync.Mutex
    num int
    foo string
}

func (outer *outer) modify(wg *sync.WaitGroup) {
    outer.Lock()
    defer outer.Unlock()
    outer.num = outer.num + 1
    wg.Done()
}

func main() {
    outer := outer{
        num: 2,
        foo: "hi",
    }
    var w sync.WaitGroup
    for j := 0; j < 5000; j++ {
        w.Add(1)
        go outer.modify(&w)
    }
    w.Wait()
    fmt.Printf("Final is %+v", outer)

}

Когда я бегу выше, напечатанный ответ всегда корректен, т.е. всегда num 5002. Без блокировки ответ непредсказуемкак и ожидалось из-за гонки между goroutines, созданной в forloop.

Однако, когда я запускаю это с -race, обнаруживается следующее состояние гонки: 


go run -race random.go
==================
WARNING: DATA RACE
Read at 0x00c00000c060 by main goroutine:
  main.main()
      random.go:32 +0x15d

Previous write at 0x00c00000c060 by goroutine 22:
  sync/atomic.AddInt32()
      /usr/local/go/src/runtime/race_amd64.s:269 +0xb
  sync.(*Mutex).Unlock()
      /usr/local/go/src/sync/mutex.go:182 +0x54
  main.(*outer).modify()
      random.go:19 +0xb7

Goroutine 22 (finished) created at:
  main.main()
      random.go:29 +0x126
==================
Final is {Mutex:{state:0 sema:0} num:5002 foo:hi}Found 1 data race(s)
exit status 66

Т.е. это обнаружение гонки между финальным Printf и одной случайной процедурой, созданной перед ним. Поскольку я использую ожидание для синхронизации, все процедуры go завершаются к тому времени, когда мы добираемся до Printf.

В чем причина сообщения о расе?

Нужно ли блокировать и печать структуры?

Ответы [ 2 ]

5 голосов
/ 02 ноября 2019

Неправильное использование sync.WaitGroup является причиной вашей расы. Любой из них должен работать должным образом: 

func (outer *outer) modify(wg *sync.WaitGroup) {
    outer.Lock()
    outer.num = outer.num + 1
    outer.Unlock()
    wg.Done()
}

func (outer *outer) modify(wg *sync.WaitGroup) {
    outer.Lock()
    defer wg.Done()
    defer outer.Unlock()
    outer.num = outer.num + 1
}

wg.Done() следует вызывать ПОСЛЕ разблокировки мьютекса (отложенные вызовы выполняются в режиме LIFO), так как вызов этого ранее вызовет вызов Printf()чтобы набрать последний outer.Unlock() вызов для доступа к outer.

1 голос
/ 02 ноября 2019 
package main

import (
    "fmt"
    "sync"
)

type outer struct {
    *sync.Mutex
    num int
    foo string
}

func (outer *outer) modify(wg *sync.WaitGroup) {
    outer.Lock()
    defer outer.Unlock()
    outer.num++
    wg.Done()
}

func main() {
    outer := outer{
        Mutex: &sync.Mutex{},
        num:   2,
        foo:   "hi",
    }
    w := &sync.WaitGroup{}
    for j := 0; j < 5000; j++ {
        w.Add(1)
        go outer.modify(w)
    }
    w.Wait()
    fmt.Printf("Final is %+v", outer)
}

изменить sync.Mutex на указатель.

Я думаю, что это из-за sync.Mutex является значением в вашей версии

...