Method queueTask

Libraries/Threading/ThreadPool.cpp:218–244

}

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

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

    SC_TRY_MSG(task.threadPool != this, "Trying to queue a task that has already been queued");
    SC_TRY_MSG(task.threadPool == nullptr, "Trying to queue a task that is already in use by another threadpool");

    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;
        taskTail       = &task;
    }
    taskAvailable.broadcast();
    return Result(true);
}