Function SelectAndPopJob

engine/dlib/src/dlib/jobsystem.cpp:488–521

}

static HJob SelectAndPopJob(JobThreadContext* ctx, uint64_t time, JobItem** out_item)
{
    uint32_t size = ctx->m_Work.Size();
    for (uint32_t i = 0; i < size;)
    {
        HJob hjob = ctx->m_Work[i];
        JobItem* item = GetJobItem(ctx, hjob);

        bool children_finished = item->m_NumChildren == item->m_NumChildrenCompleted;

        // Check if the item meets our criteria
        if (item->m_Status == JOBSYSTEM_STATUS_CANCELED && children_finished)
        {
            size--;
            ctx->m_Work.Erase(i);
            PutDone(ctx, hjob, JOBSYSTEM_STATUS_CANCELED, 0);
            continue;
        }

        if (!children_finished)
        {
            // Still waiting for the children to finish
            ++i;
            continue;
        }

        // The item is selected and removed from the array
        ctx->m_Work.Erase(i);
        *out_item = item;
        return hjob;
    }
    *out_item = 0;
    return INVALID_JOB;
}

// Good for unit testing with/without threads enabled
static void UpdateSingleThread(JobThreadContext* ctx, uint64_t max_time)