Method ThreadProc

src/engine/ThreadPool.cpp:97–128

}

void ThreadPool::ThreadProc()
{
    while(!m_terminate.load())
    {
        std::shared_ptr<ThreadPoolTask> task;
        
        // Wait until a task is available or termination is requested
        {
            std::unique_lock<std::mutex> lock(m_mutex);
            m_forward.wait(lock, [this] { return !m_tasks.empty() || m_terminate.load(); });

            if (!m_tasks.empty())
            {
                task = std::move(m_tasks.front());
                m_tasks.pop();
            }
        }

        if (task)
        {
            try
            {
                task->Run();
            }
            catch(...)
            {
                // Ignore task exceptions
            }
            --m_pendingTasks;
        }
    }
}

}