//----------------------------------------------------
// lamport-y.cc
//----------------------------------------------------

#include <algorithm>
#include <atomic>
#include <iostream>
#include <latch>
#include <thread>

//----------------------------------------------------

using namespace std::literals;

//----------------------------------------------------

const size_t N = 32;
std::latch latch(N);
std::atomic<bool> stop = false;

//----------------------------------------------------

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)))
                std::this_thread::yield();
        }
    }

    void unlock(size_t i) { numero[i] = 0; }

private:
    std::atomic<bool> escoger[N]{false};
    std::atomic<size_t> 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 << '\n';
}

//----------------------------------------------------

void hebra(size_t i)
{
    latch.arrive_and_wait();
    while (!stop)
    {
        l.lock(i);
        if (!stop) 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);

    std::this_thread::sleep_for(75ms);
    stop = true;
}

//----------------------------------------------------