Dima TDimitry SibiryakovПроблема была бы если вы ожидание иногда не прерывалось при взведении флага.
Как понимаю такая проблема тоже есть. Например поток обработки закончил обрабатывать очередь, почти дошел до засыпания на cv.wait(), в этот момент другой поток вызывает cv.notify_one() и этот вызов игнорируется, т.к. первый не успел заснуть на cv.wait().
Dima T, такой проблемы нет. Как минимум в g++
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
class condition_variable
{
.......................
void
notify_one() noexcept
{
lock_guard<mutex> __lock(*_M_mutex);
_M_cond.notify_one();
}
void
notify_all() noexcept
{
lock_guard<mutex> __lock(*_M_mutex);
_M_cond.notify_all();
}
template<typename _Lock>
void
wait(_Lock& __lock)
{
shared_ptr<mutex> __mutex = _M_mutex;
unique_lock<mutex> __my_lock(*__mutex);
_Unlock<_Lock> __unlock(__lock);
// *__mutex must be unlocked before re-locking __lock so move
// ownership of *__mutex lock to an object with shorter lifetime.
unique_lock<mutex> __my_lock2(std::move(__my_lock));
_M_cond.wait(__my_lock2);
}
Лишнее срабатыванее ждущего рабочего потока может случится при вызове notify_all() и очередь короче количества рабочих потоков, или вообще пуста. Это стандартная ситуация.
