Function threadSystemAddTasks

Common_3/Utilities/Threading/ThreadSystem.c:295–343

}

void threadSystemAddTasks(ThreadSystem thandle, TaskFunc func, uint64_t count, uint64_t userSize, void* users)
{
    if (count == 0)
        return;
    if (!VERIFY(func))
        return;

    struct ThreadSystemData* t = thandle;

    if (!t) // dummy run
    {
        for (uint64_t ti = 0; ti < count; ++ti)
            func((uint8_t*)users + ti * userSize, 0);
        return;
    }

    acquireMutex(&t->mutex);

    uint64_t offset = t->tasksQueued;

    t->tasksQueued += count;

    uint64_t len = arrlenu(t->tasks);

    if (t->tasksQueued > len)
    {
        // Resize the task array to a multiple of OPTIMAL_TASK_SLOTS_COUNT that is large enough to contain all of the requested tasks.
        uint64_t newTasksLength = t->tasksQueued / OPTIMAL_TASK_SLOTS_COUNT;
        newTasksLength += (t->tasksQueued % OPTIMAL_TASK_SLOTS_COUNT) == 0 ? 0 : 1;
        newTasksLength *= OPTIMAL_TASK_SLOTS_COUNT;
        arrsetlen(t->tasks, newTasksLength);
    }

    for (uint64_t ti = 0; ti < count; ++ti)
    {
        t->tasks[offset + ti] = (struct ThreadSystemTask){
            func,
            users ? ((uint8_t*)users + ti * userSize) : NULL,
        };
    }

    if (count == 1)
        wakeOneConditionVariable(&t->conditionTasks);
    else
        wakeAllConditionVariable(&t->conditionTasks);

    releaseMutex(&t->mutex);
    return;
}

bool threadSystemAssist(ThreadSystem thandle)
{