//----------------------------------------------------
// flag3.cc: std::atomic_flag con wait/notify_one
//----------------------------------------------------

#include <atomic>
#include <iostream>
#include <thread>

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

using namespace std::literals;

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

const size_t N = 8;

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

class cerrojo
{
public:
    void adquirir()
    {
        while (cerrado.test(std::memory_order_relaxed) ||
               cerrado.test_and_set(std::memory_order_acq_rel))
            cerrado.wait(true, std::memory_order_relaxed);
    }

    void liberar()
    {
        cerrado.clear(std::memory_order_release);
        cerrado.notify_one();
    }

private:
    std::atomic_flag cerrado;
} c;

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

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()
{
    while (true)
    {
        c.adquirir();
        seccion_critica();
        c.liberar();
    }
}

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

int main()
{
    std::jthread threads[N];

    for (auto &i : threads)
        i = std::jthread(hebra);
}

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