Method queueTask

Libraries/Threading/ThreadPool.cpp:218–244

        {
            break; // all tasks have completed (including the task being waited)
        }
    }
    return ResultThreading(true);
}

SC::ResultThreading SC::ThreadPool::queueTask(Task& task)
{
    if (numWorkerThreads == 0)
        return ResultThreading(ThreadingError::ThreadPoolNotCreated);

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

    if (task.threadPool == this)
        return ResultThreading(ThreadingError::TaskAlreadyQueued);
    if (task.threadPool != nullptr)
        return ResultThreading(ThreadingError::TaskInUseByAnotherThreadPool);

    task.threadPool = this;
    if (taskHead == nullptr)
    {
        // FIFO was empty, replace head and tail with the task
        taskHead = &task;
        taskTail = taskHead;
    }
    else
    {
        // FIFO was not empty, append task to the tail
        taskTail->next = &task;