//---------------------------------------------------- // lamport.cc //---------------------------------------------------- #include #include #include #include //---------------------------------------------------- using namespace std::literals; //---------------------------------------------------- const size_t N = 8; //---------------------------------------------------- class lamport { public: void lock(size_t i) { escoger[i] = true; numero[i] = *std::ranges::max_element(numero) + 1; escoger[i] = false; for (size_t j = 0; j < N; ++j) { while (escoger[j]) ; while (numero[j] != 0 && (numero[j] < numero[i] || (numero[j] == numero[i] && j < i))) ; } } void unlock(size_t i) { numero[i] = 0; } private: std::atomic escoger[N]{false}; std::atomic numero[N]{0}; } l; //---------------------------------------------------- void seccion_critica() { std::cout << "[" << std::this_thread::get_id() << "]: "; for (size_t i = 0; i < 10; ++i) std::cout << i; std::cout << std::endl; } //---------------------------------------------------- void hebra(size_t i) { while (true) { l.lock(i); seccion_critica(); l.unlock(i); } } //---------------------------------------------------- int main() { std::jthread threads[N]; for (size_t i = 0; i < N; ++i) threads[i] = std::jthread(hebra, i); } //----------------------------------------------------