Как понять работу sync.Cond в golang?

Question

[Алексей Верховцев]

Всем привет, пытаюсь понять работу sync.Cond. Но что-то не получается, мой пример

c := sync.NewCond(&sync.Mutex{})
	var wg sync.WaitGroup

	wg.Add(1)
	go func() {
		wg.Done()
		c.L.Lock()
		defer c.L.Unlock()
		c.Wait()
		fmt.Println("I'm created")
	}()

	c.Signal()
	wg.Wait()

Эта строчка fmt.Println("I'm created") никогда не вызывается... Примеры других примеров нашел в книгах, но они все другие и я не могу понять сам процесс работы. По идее, я в горутине ожидаю сигнала, в конце его посылаю и горутина должна разблокироваться, но как-то не работает(. Если ставлю wg.Done в конце, то вообще получаю дедлок

Answer 1

[Евгений Самсонов]

Первая ошибка это вызов wg.Done сразу в начале функции. wg.Done() нужно вызывать перед завершением. Вторая ошибка это предположение, что когда мы вызываем c.Signal() мы уже дошли до c.Wait().

c := sync.NewCond(&sync.Mutex{})
var wg sync.WaitGroup

wg.Add(1)
go func() {
    defer wg.Done()
    c.L.Lock()
    defer c.L.Unlock()
    c.Wait()
    fmt.Println("I'm created")
}()

time.Sleep(1 * time.Second)		
c.Signal()
wg.Wait()

https://play.golang.org/p/fuSnDNTGYeZ

sync.Cond позволяет синхронизироваться горутинам по событиям, заменить бесконечный цикл ожидания какого-нибудь определенного условия. Это полезно, например, если мы хотим разблокировать сразу несколько горутин (Broadcast), что не получится сделать с помощью канала. Метод Signal отправляет сообщение самой долгой ожидающей горутине

Comments

[Алексей Верховцев]

Спасибо большое, но получается, что мы здесь решаем проблему race condition только таймаутом, но ведь это не совсем здорово, а вдруг горутина запоздает более чем на 1 секунду, способа лучше нет?

[Евгений Самсонов]

Алексей Верховцев, Этот код же синтетический пример. Представьте, что вместо таймаута выполняется какая-то длительная работа, после которой горутина должна разблокироваться

[Алексей Верховцев]

Евгений Самсонов, но риск все равно есть, как я понимаю и мы не можем ничего с этим поделать? Пример в вакууме, конечно, но всякое бывает, вдруг что-то заглючило, как обычно такое решается?

[Евгений Самсонов]

Алексей Верховцев, В этом примере для понимания не хватает условия. Допустим есть ресурс, освобождение которого мы ожидаем в горутине. Мы можем написать бесконечный цикл с проверкой ресурса, но так мы займем cpu бесполезной работой. Мы можем опрашивать в бесконечном цикле с таймаутом, но узнаем о свободном ресурсе позднее, чем хотелось бы. Лучший вариант, это когда нас оповестят о свободном ресурсе c помощью sync.Cond. В данном случае даже без таймаута мы не заблокируемся

c := sync.NewCond(&sync.Mutex{})
var wg sync.WaitGroup
	
free := true

wg.Add(1)
go func() {
    defer wg.Done()
    c.L.Lock()
    defer c.L.Unlock()
    for !free {   // Проверяем, что ресурс свободен
       c.Wait()
    }
    fmt.Println("I'm created")
}()
  
free = false // Забрали ресурс, чтобы выполнить с ним работу
time.Sleep(1 * time.Second)   // Эмуляция работы
free = true  // Освободили ресурс
c.Signal()   // Оповестили горутину

wg.Wait()

https://play.golang.org/p/rDJvTRceJ3I

Надеюсь, понятно объяснил

[Евгений Самсонов]

Алексей Верховцев, UPDATE обновил код в комментарии выше, там вместо if !free должно быть for !free