Buscar..
Introducción
Los semáforos no están disponibles en C ++ a partir de ahora, pero se pueden implementar fácilmente con un mutex y una variable de condición.
Este ejemplo fue tomado de:
Semáforo C ++ 11
#include <mutex>
#include <condition_variable>
class Semaphore {
public:
Semaphore (int count_ = 0)
: count(count_)
{
}
inline void notify( int tid ) {
std::unique_lock<std::mutex> lock(mtx);
count++;
cout << "thread " << tid << " notify" << endl;
//notify the waiting thread
cv.notify_one();
}
inline void wait( int tid ) {
std::unique_lock<std::mutex> lock(mtx);
while(count == 0) {
cout << "thread " << tid << " wait" << endl;
//wait on the mutex until notify is called
cv.wait(lock);
cout << "thread " << tid << " run" << endl;
}
count--;
}
private:
std::mutex mtx;
std::condition_variable cv;
int count;
};
Clase de semáforo en acción.
La siguiente función agrega cuatro hilos. Tres hilos compiten por el semáforo, que se establece en una cuenta de uno. Un subproceso más lento llama a notify_one()
, lo que permite que uno de los subprocesos en espera continúe.
El resultado es que s1
comienza a girar de inmediato, lo que hace que el count
uso del Semáforo permanezca por debajo de 1. Los otros subprocesos esperan, a su vez, la variable de condición hasta que se llama a notificar ().
int main()
{
Semaphore sem(1);
thread s1([&]() {
while(true) {
this_thread::sleep_for(std::chrono::seconds(5));
sem.wait( 1 );
}
});
thread s2([&]() {
while(true){
sem.wait( 2 );
}
});
thread s3([&]() {
while(true) {
this_thread::sleep_for(std::chrono::milliseconds(600));
sem.wait( 3 );
}
});
thread s4([&]() {
while(true) {
this_thread::sleep_for(std::chrono::seconds(5));
sem.notify( 4 );
}
});
s1.join();
s2.join();
s3.join();
s4.join();
...
}
Modified text is an extract of the original Stack Overflow Documentation
Licenciado bajo CC BY-SA 3.0
No afiliado a Stack Overflow