Потоко-безопасная Очередь

#include <iostream>
#include <thread>
#include <condition_variable>
#include  <mutex>
#include <chrono>
#include <queue>
 
using namespace std;
 
  bool bDone;
  mutex m;
  std::condition_variable cv;
 
int main() {
    int c = 0;
    bool done = false;
    queue<int> goods;
 
    thread producer([&]() {
        std::lock_guard<mutex> lock(m);
        for (int i = 0; i < 500; ++i) {            
            goods.push(i);
            c++;
            cv.notify_one();
        }
 
        done = true;
    });
 
    thread consumer([&]() {
        std::unique_lock<mutex> lock(m);
        while (!done) {
            while (!goods.empty()) {
                goods.pop();
                c--;
                while (!bDone) cv.wait(lock);
            }
        }
    });
 
    producer.join();
    consumer.join();
    cout << "Net: " << c << endl;
}

while (!bDone) cv.wait(lock;[=]{return bDone=true;});

        while (!done) {
            while (!goods.empty()) {

    mutex m;
    std::condition_variable cv;
    int c = 0;
    bool done = false;
    queue<int> goods;
 
    thread producer([&]() {        
        for (int i = 0; i < 500; ++i) { 
            {
                std::lock_guard<mutex> lock(m);           
                goods.push(i);
                c++;
            }
            cv.notify_one();
        }
        std::lock_guard<mutex> lock(m);
        done = true; // <- нужна блокировка(атомарность как минимум)
    });
 
    thread consumer([&]() {
        for(;!(done && goods.empty());) { // завершаем только когда очередь пуста и пополнений больше не будет
            std::unique_lock<mutex> lock(m);    
            cv.wait(lock, [&goods]{ return !goods.empty(); }); // тут только ожидание уведомления об очередном сообщении в очереди
            c--;
            goods.pop();
        }
    });

#include <iostream>
#include <thread>
#include <condition_variable>
#include <mutex>
#include <chrono>
#include <queue>
using namespace std;
 
int main() {
    int c = 0;
    bool done = false;
    queue<int> goods;
 
    mutex m;
    std::condition_variable cv;
    std::condition_variable cv2;
 
    thread producer([&]() {
 
        std::unique_lock<std::mutex> lk(m);
        for (int i = 0; i < 500; ++i) {
            goods.push(i);
            c++;
 
            if ((i % 10) == 0)
            {
                cv.notify_one();
                cv2.wait(lk);
            }
        }
 
        done = true;
        cv.notify_one();
        });
 
    thread consumer([&]() {
 
        std::unique_lock<std::mutex> lk(m);
        while (!done) {
            cv.wait(lk, [&done, &goods] {return (done || !goods.empty()); });
            while (!goods.empty())
            {
                goods.pop();
                c--;
            }
            cv2.notify_one();
        }
        });
 
    producer.join();
    consumer.join();
    cout << "Net: " << c << endl;
}

while (!bDone) cv.wait(lock, [&]{return bDone=false;});