//--------------------------------------------------------- // shared_lock.cc //--------------------------------------------------------- #include #include #include #include #include #include #include //--------------------------------------------------------- using namespace std; //--------------------------------------------------------- atomic run(true); shared_mutex m; //--------------------------------------------------------- void seccion_critica(char c) { for (char i = 0; i < 10; ++i) cout << c; cout << endl; } //--------------------------------------------------------- void lector(char c) { while (run) { shared_lock l(m); seccion_critica(c); } } //--------------------------------------------------------- void escritor(char c) { while (run) { unique_lock l(m); seccion_critica(c); } } //--------------------------------------------------------- int main() { const unsigned N = 8; thread lectores[N], escritores[N]; std::default_random_engine engine; for (unsigned i = 0; i < N; ++i) if (engine() & 1) { lectores[i] = thread( lector, '0' + i); escritores[i] = thread(escritor, 'a' + i); } else { escritores[i] = thread(escritor, 'a' + i); lectores[i] = thread( lector, '0' + i); } this_thread::sleep_for(100ms); run = false; for(thread& i: lectores) i.join(); for(thread& i: escritores) i.join(); } //---------------------------------------------------------