Condition_Variable_02_Simple.cpp

// ===========================================================================
// Condition_Variable_02_Simple.cpp // Condition Variable
// ===========================================================================

#include <iostream>
#include <thread> 
#include <mutex> 
#include <chrono>

#include "../Logger/Logger.h"

namespace SimpleConditionVariableDemo02
{
    static constexpr long NumIterations{ 5 };

    static std::mutex mutex;

    static std::condition_variable condition;

    static void function()
    {
        std::thread::id tid{ std::this_thread::get_id() };
        Logger::log(std::cout, "TID:  ", tid);

        std::unique_lock<std::mutex> guard{ mutex };
        condition.wait(guard);

        Logger::log(std::cout, "Done Thread ", tid);
    }

    static void test()
    {
        std::thread::id mainTID{ std::this_thread::get_id() };
        Logger::log(std::cout, "Begin Main: ", mainTID);

        std::thread t1{ function };
        std::thread t2{ function };

        std::this_thread::sleep_for(std::chrono::seconds{ 2 });

        condition.notify_one();     // demonstrate either this line
        // condition.notify_all();  // or this line

        std::this_thread::sleep_for(std::chrono::seconds{ 2 });
        condition.notify_one();     // and this line

        t1.join();
        t2.join();

        Logger::log(std::cout, "Done Main.");
    }
}

void test_simple_condition_variable_02()
{
    using namespace SimpleConditionVariableDemo02;
    test();
}

// ===========================================================================
// End-of-File
// ===========================================================================