Асинхронность и Семафор

#include <iostream>
#include <semaphore.h>
#include <future>
#include <thread>
#include <vector>
#include <Windows.h>
 
using namespace std;
 
int main(int argc, const char *argv[])
{
    std::vector<std::future<void>> futures;
    sem_t semaphore1;
    
    sem_init(&semaphore1, 0, 1);    // 1 - бинарный семафор (can have 0 or 1)
    for (int i = 0; i < 10; ++i) { 
        futures.push_back(std::async(launch::async, [&semaphore1, i]
        {   
            Sleep(1000);       
            
            sem_wait(&semaphore1);  // decrements the semaphore, if 0 - then blocking sem.
            Sleep(100);
         
            cout <<"Hello world " << i << endl; 
              
            sem_post(&semaphore1);          // increments the semaphore that is being waited => smbd becomes awakened
        }));  
 
    }    
 
    for (auto &fut : futures) {
        fut.get();
        
    }
    
    sem_destroy(&semaphore1);
    return 0;
}

    while (!b_gate_open) cv_oGate.wait(lock);

#include <iostream>
#include <semaphore.h>
#include <future>
#include <vector>
#include <Windows.h>
 
using namespace std;
 
int main(int argc, const char *argv[])
{
    std::vector<std::future<void>> futures;
    sem_t semaphore1;
    
    sem_init(&semaphore1, 0, 1);
    for (int i = 0; i < 10; ++i) { 
        futures.push_back(std::async(launch::async, [&semaphore1, i]
        {   
       /*sem_trywait() is the same as sem_wait(), except that if the
       decrement cannot be immediately performed, then call returns an
       error (errno set to EAGAIN) instead of blocking.
       */
       /*
       EAGAIN The operation could not be performed without blocking (i.e., the semaphore currently has the value zero).
        */
          
        // Do something while sem_wait in C  
            for (;;) {
              if (sem_trywait(&semaphore1)) {
                 if (errno != EAGAIN) {
                     /* handle error */
                     abort();                    
                 }
                 errno = 0;              
                 //can do smth you want 
                 
              } else {
                  cout <<"continue this " << i << endl;
                 break;
              }
            }
         
            cout <<"Hello world " << i << endl; 
  
            sem_post(&semaphore1);
        }));  
 
    }    
 
    for (auto &fut : futures) {
        fut.get();
        
    }
    
    sem_destroy(&semaphore1);
    return 0;
}