start_conditional_thread()

void MayaFlux::Vruta::TaskScheduler::start_conditional_thread ( )

private

Start the conditional task processing thread if not already running.

This method ensures that the thread responsible for processing conditional tasks is started when the first conditional task is added. It checks if the thread is already running to avoid starting multiple threads.

Definition at line 443 of file Scheduler.cpp.

{
    if (m_conditional_thread.joinable())
        return;
 
#if MAYAFLUX_USE_JTHREAD
    m_conditional_thread = std::jthread([this](const std::stop_token& st) {
        while (!st.stop_requested())
            pump_conditional();
    });
#else
    m_conditional_stop.store(false, std::memory_order_release);
    m_conditional_thread = std::thread([this]() {
        while (!m_conditional_stop.load(std::memory_order_acquire))
            pump_conditional();
    });
#endif
}

References m_conditional_stop, m_conditional_thread, and pump_conditional().

Referenced by add_task().

Here is the call graph for this function:

Here is the caller graph for this function: