станд :: condition_variable :: notify_one() вызывается дважды

Question

Сколько ожидающий поток проснётся, если я позвоню станд :: condition_variable :: notify_one() дважды без какого-либо временного интервала, например:

{ 
    std::unique_lock<std::mutex> lock(condvar_mutex); 

    condvar.notify_one(); 
    condvar.notify_one(); 
} 

ли есть ли гарантия, что эти уведомления будут доставлены в разные потоки, а не один и тот же поток несколько раз?

Answer 1

§30.5.1.7: Если любые потоки заблокированы в ожидании * этого, разблокирует один из этих тем.

Там нет никакой гарантии, что это разные темы, так что это один нить. В течение времени между двумя вызовами notify_one возможно, что тот же самый поток, который просыпался с первым notify_one, повторно блокируется.

например. В следующем примере не гарантируется, просыпается ли поток 3 или нет (не обращайте внимания на побочные следы для этого примера).

- thread 1: 

1 condvar.notify_one(); 
- 3 and 4 could run here. 
2 condvar.notify_one(); 

- thread 2: 

3 condvar.wait(/*...*/); 
4 condvar.wait(/*...*/); 

- thread 3: 

5 condvar.wait(/*...*/); 

Answer 2

Я предполагаю, что condvar_mutex является правильным мьютекс для condvar.

Невозможно, чтобы оба уведомления доставлялись в одну и ту же резьбу. Причина в том, что вы звоните notify_one дважды , удерживая мьютексы. Итак, какая бы ни была разблокирована нить, сначала невозможно получить мьютекс, поэтому он не может вернуться с wait. Он не может даже выбросить исключение из wait_for без предварительного получения мьютекса.

Поскольку он не может выбраться из своего ожидания, он не сможет вернуться к списку официантов до того, как будет вызван второй notify_one.

Итак, ваш код разблокирует до двух потоков, заблокированных на condvar, если их так много. Если их меньше, то дополнительные уведомления не влияют.