Function threadSystemInit

Common_3/Utilities/Threading/ThreadSystem.c:176–265

}

bool threadSystemInit(ThreadSystem* out, const struct ThreadSystemInitDesc* desc)
{
    *out = NULL;
    if (desc->threadCount == 0) // dummy run
        return true;

    uint64_t cpuCount = getNumCPUCores();
    uint64_t count = desc->threadCount;

    if (count > cpuCount)
        count = cpuCount;

    if (count == 0) // something went wrong (maybe getNumCPUCores returned 0)
        return false;

    struct ThreadSystemData* t = tf_calloc(1, sizeof(*t) + sizeof(ThreadHandle) * count);
    if (!t)
        return false;

    t->threads = (ThreadHandle*)(t + 1);
    t->name = desc->threadName ? desc->threadName : "ThreadSystem";

    bool success = false;

    do
    {
        if (!initMutex(&t->mutex))
        {
            memset(&t->mutex, 0, sizeof t->mutex);
            break;
        }

        if (!initConditionVariable(&t->conditionTasks))
        {
            memset(&t->conditionTasks, 0, sizeof t->conditionTasks);
            break;
        }

        if (!initConditionVariable(&t->conditionIsIdle))
        {
            memset(&t->conditionIsIdle, 0, sizeof t->conditionIsIdle);
            break;
        }

        success = true;
    } while (false);

    if (!success)
    {
        threadSystemCleanup(t);
    }

    ThreadDesc threadDesc = { 0 };

    threadDesc.pFunc = taskThreadFunc;
    threadDesc.pData = t;

#if defined(_WINDOWS) // for some reason on Windows thread name won't change after creation