Condition_variable - как заставить работать все пробужденные потоки

int global_int = 0;
mutex my_mutex;
condition_variable my_cond_var;
 
 
int main()
{
 
//---------------------------------
//Создаю два потока:
std::thread my_threads[2];
 
for (int i = 0; i < 2; ++i)
{
       my_threads[i] = std::thread(cout_id, i);
}
//---------------------------------
 
 
global_int = 1;                    //Устанавливаю статус для пробуждения потоков 
my_cond_var.notify_all();    //пробуждаю все потоки
 
 
 
 
for (int i = 0; i < 2; ++i)
    {
       my_threads[i].join();
    }
 
}

void cout_id(int id)
{
    std::unique_lock<std::mutex> lck(my_mutex, defer_lock);
    
 
 
    while(global_int == 0)
    {
        my_cond_var.wait(lck);
    }
    
 
    std::cout << "thread_start " << id << endl;
    this_thread::sleep_for(chrono::milliseconds(10000));
    std::cout << "thread_end " << id << endl;
}

#include <thread>
#include <mutex>
#include <iostream>
 
int global_int = 0;
std::mutex my_mutex;
std::condition_variable my_cond_var;
 
void cout_id(int id)
{
    std::unique_lock<std::mutex> lck(my_mutex);
    my_cond_var.wait(lck, [] { return global_int != 0; });
 
 
    std::cout << "thread_start " << id << std::endl;
    lck.unlock();
    std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    lck.lock();
    std::cout << "thread_end " << id << std::endl;
}
 
int main()
{
 
    //---------------------------------
    //Создаю два потока:
    std::thread my_threads[2];
 
    for (int i = 0; i < 2; ++i)
    {
        my_threads[i] = std::thread(cout_id, i);
    }
    //---------------------------------
    std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    {
        std::lock_guard<std::mutex> lck(my_mutex);
        global_int = 1;                    //Устанавливаю статус для пробуждения потоков
        std::cout << "notify\n";
    }
    my_cond_var.notify_all();    //пробуждаю все потоки
 
 
 
 
    for (int i = 0; i < 2; ++i)
    {
        my_threads[i].join();
    }
 
}

    std::unique_lock<std::mutex> lck(my_mutex);

  {
    std::unique_lock<std::mutex> lck(my_mutex);
    global_int = 1;
  }
  my_cond_var.notify_all();

int main()
{
    std::thread my_threads[500];
 
    for (int i = 0; i < 500; ++i)
    {
        my_threads[i] = std::thread(cout_id, i);
    }
 
 
    global_int = 1;
 
 
 
    for (int i = 0; i < 100; ++i)
    {
        my_threads[i].join();
    }
 
}

void cout_id(int id)
{
    while (global_int == 0)
    {
        this_thread::sleep_for(chrono::milliseconds(10));
    }
 
    std::cout << "thread_start " << id << endl;
    this_thread::sleep_for(chrono::milliseconds(10000));  //Какая то работа
    std::cout << "thread_end " << id << endl;
}

    std::unique_lock<std::mutex> lck(my_mutex);
    my_cond_var.wait(lck, [] { return global_int != 0; });  //<--- unlock and wait
 
    std::cout << "thread_start " << id << std::endl;
    lck.unlock();   //<--- already unlocked

lck.unlock();
lck.unlock();