Многопоточность. Condition_variable. Как проверить одновременно две переменных?

// test_Threads2.cpp
//
#include <iostream>
#include <string>
#include <windows.h>
#include <queue>
#include <thread>
#include <mutex>
#include <atomic>
#include <condition_variable>
#include <random>
 
#define NUMBER1 42
#define NUMBER2 35
 
 
std::random_device rd;
std::queue<std::wstring> que;
std::mutex mtx, g_lockprint;
std::condition_variable cv;
std::atomic_bool startFlag = false, exitFlag = false, dataReady = false;
 
int GetRandom(int m, int n) {
    std::mt19937 gen(rd());
    std::uniform_int_distribution<> distrib(m, n);
    return distrib(gen);
}
 
// Имитация работы потока. Поток должен работать до завершения программы.
// При совпадении условия генерируется строка, блокируется мютекс, строка помещается в очередь.
// После чего устанавливается флаг готовности данных и подётся сигнал потоку-Читателю.
void Writer1() {
    // Стартовое сообщение. Подсмотрел на Хабре.
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Writer-1 running..." << std::endl;
    }
 
    // Тоже на Хабре подсмотрел.
    // Старт всех потоков по одному сигналу.
    while (!startFlag.load()) std::this_thread::yield;
 
    int r = 0; uint64_t i = 0; std::wstring s;
 
    while (false == exitFlag.load()) {
        r = GetRandom(0, 1000);
        //std::wcout << L"i: " << i << L"\tr = " << r << L"                            \r";
        if (r == NUMBER1) {
            s = L"Number " + std::to_wstring(NUMBER1) + L": iteration #" + std::to_wstring(i);
            {
                std::unique_lock<std::mutex> locker(mtx);
                que.push(s);
                dataReady = true;
            }
            cv.notify_one();
        }
        ++i;
    }
 
    // Сообщение о завершении
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Writer-1 stopped." << std::endl;
    }
}
 
//// Имитация работы потока аналогично первому.
void Writer2() {
    // Стартовое сообщение. Подсмотрел на Хабре.
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Writer-2 running..." << std::endl;
    }
 
    // Тоже на Хабре подсмотрел.
    // Старт всех потоков по одному сигналу.
    while (!startFlag.load()) std::this_thread::yield;
 
    int r = 0; uint64_t i = 0; std::wstring s;
 
    while (false == exitFlag.load()) {
        r = GetRandom(0, 1000);
        //std::wcout << L"i: " << i << L"\tr = " << r << L"                            \r";
        if (r == NUMBER2) {
            s = L"Number " + std::to_wstring(NUMBER2) + L": iteration #" + std::to_wstring(i);
            {
                std::unique_lock<std::mutex> locker(mtx);
                que.push(s);
                dataReady = true;
            }
            cv.notify_one();
        }
        ++i;
    }
 
    // Сообщение о завершении
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Writer-2 stopped." << std::endl;
    }
}
 
// Поток-читатель. Должен работать до окончания работы программы.
// При получении сигнала от Писателя должен заблокировать мютекс,
// вывести на экран строки из очереди, удалить эти строки из очереди
// и разблокировать мютекс.
void Reader() {
    // Стартовое сообщение
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Reader running..." << std::endl;
    }
    while (!startFlag.load()) std::this_thread::yield;
 
    while (false == exitFlag.load()) {
        {
            std::unique_lock<std::mutex> locker(mtx);
            cv.wait(locker, []() { return dataReady.load(); });
            if (!que.empty()) {
                for (; !que.empty(); que.pop()) {
                    std::wcout << que.front() << std::endl;
                }
            }
            dataReady = false;
        }
        if (true == exitFlag.load()) break; // Добавление этой проверки не помогает.
    }
 
    // Сообщение о завершении
    {
        std::unique_lock<std::mutex> locker(g_lockprint);
        std::cout << "Reader stopped." << std::endl;
    }
}
 
int main() {
    setlocale(LC_ALL, ".UTF8");
    SetConsoleOutputCP(CP_UTF8);
    std::wcout << L"Start main thread" << std::endl;
    std::wcout << L"Press ESC to exit or CTRL+C to break" << std::endl;
 
    exitFlag = false;
    dataReady = false;
 
    std::thread t0(Reader);
    std::thread t1(Writer1);
    std::thread t2(Writer2);
 
    startFlag = true;
 
    // Имитация бесконечной работы основного потока, до прерывания пользователем.
    while (!(GetAsyncKeyState(VK_ESCAPE) & 0x8000)) {}
 
    // При нажатии на ESC устанавливается флаг для остановки всех остальных потоков и подётся сигнал.
    exitFlag = true;
    cv.notify_one();
 
    t1.join();
    t2.join();
    t0.join();
 
    std::wcout << L"\nQueue size: " << que.size() << std::endl;
 
    std::wcout << L"End main thread" << std::endl;
    return 0;
}

(false == exitFlag.load())

{
   std::unique_lock<std::mutex> locker(mtx);
   if (!exitFlag.load())
     queue.push(s);
   dataReady = true;
}
cv.notify_one();

cv.wait(locker, []() { return !queue.empty() || exitFlag.load(); });

while (false == exitFlag.load()) {

bool done = false;
while (!done) {
//..
 {
   std::unique_lock<std::mutex> locker(mtx);
   done = exitFlag.load();
   if (!done)
    queue.push(s);
  }
  cv.notify_one();
}

bool done = false;
while (!done) {
    std::unique_lock<std::mutex> locker(mtx);
    cv.wait(locker, []() { return !queue.empty() || exitFlag.load(); });
    done = exitFlag.load();
    for (; !queue.empty(); queue.pop()) 
      std::wcout << queue.back() << std::endl;
}