Method waitForTask

Libraries/Threading/ThreadPool.cpp:192–216

}

SC::Result SC::ThreadPool::waitForTask(Task& task)
{
    SC_TRY_MSG(numWorkerThreads > 0, "Cannot wait for tasks on an uninitialized threadpool");

    // Function is entirely protected by the mutex
    poolMutex.lock();
    auto deferUnlock = MakeDeferred([this] { poolMutex.unlock(); });

    for (;;)
    {
        if (task.threadPool == nullptr)
        {
            break; // The task being waited has been flagged as completed
        }
        if (taskHead != nullptr or numRunningTasks != 0)
        {
            taskCompleted.wait(poolMutex);
        }
        else
        {
            break; // all tasks have completed (including the task being waited)
        }
    }
    return Result(true);
}

SC::Result SC::ThreadPool::queueTask(Task& task)
{