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

Question

[simply_user]

Здравствуйте!
Пишу программу для обработки текста из файла. Код построен по принципу "поставщик-потребитель". Для блокирования потребителя использую condition_variable. При использовании первой перегрузки метода wait (без предиката) всё работает нормально. Но, если использовать вторую перегрузку, с предикатом, то получается вот такая ситуация: поставщику достаточно отправить хотя бы один сигнал, чтобы ожидающий поток потребителя разблокировался и больше он уже не блокируется, даже если сигнал не был больше послан. Хочу обратить внимание, что данное поведение имеет место быть только при использовании предиката (я в лямбда-выражении проверяю, что очередь не пуста). Почему так происходит?
Заранее спасибо!
Код:

unique_lock<mutex> lockM(signalMutex);
				conVar.wait(lockM, []{return !Producer::dataProcessing.empty(); });
				buffer = Producer::dataProcessing.front();
				Producer::dataProcessing.pop();
				lockM.unlock();

Answer 1

[DISaccount]

Очевидно, что условие return !Producer::dataProcessing.empty(); все время возвращает true.
Читаем внимательно:

If pred is specified (2), the function only blocks if pred returns false, and notifications can only unblock the thread when it becomes true

Comments

[simply_user]

Это да, но тогда получается разблокировка зависит не от получения сигнала, а от значения которое возвращает предикат(true или false)? Как я понимаю эта проверка нужна для того, чтобы при ПОЛУЧЕНИИ сигнала исключить т.н "случайный выход".

[DISaccount]

simply_user: Да, notify_one() или notify_all() работает как "спусковой крючок". Далее проверяется предикат и пока он == true, блокировки нет. Вообще, более разумно либо сделать локальную копию dataProcessing и отчистить его со снятием блокировки, либо организовать цикл по этому контейнеру с обработкой элементов, а после обработки, опять таки, отчистить его и снять блокировку.

[simply_user]

DISaccount: Спасибо. Но почему тогда первая перегрузка метода wait, работает иначе? Т.е при её использовании поток разблокируется только тогда, когда будет получен сигнал.

[DISaccount]

simply_user: Потому что wait без предиката именно так и спроектирован - пробуждаться по сигналу. Причем в этой перегрузке так же возможны "случайные пробуждения". И по правилам хорошего тона, следует проверять дополнительное условие, чтобы удостоверится, что пробуждение не случайное. Для этого и ввели перегрузку wait с предикатом, но в этой перегрузке, пошли ты хоть 100500 notify_all(), блокировка не снимется, пока предикат не вернет true. И опять же, пока предикат == true и был послан сигнал, блокировки не будет. Как только предикат == false и нет сигналов, блокировка возобновиться.