Function JobThread

engine/dlib/src/dlib/jobsystem.cpp:546–577

#if defined(DM_HAS_THREADS)
static void JobThread(void* _ctx)
{
    JobThreadContext* ctx = (JobThreadContext*)_ctx;
    while (true)
    {
        HJob hjob = 0;
        {
            DM_MUTEX_SCOPED_LOCK(ctx->m_Mutex);

            if (!ctx->m_Run)
                break;

            while(ctx->m_Work.Empty())
            {
                dmConditionVariable::Wait(ctx->m_WakeupCond, ctx->m_Mutex);
                if (!ctx->m_Run)
                    return;
            }

            uint64_t time = dmTime::GetMonotonicTime();
            JobItem* item = 0;
            hjob = SelectAndPopJob(ctx, time, &item);
            if (hjob == INVALID_JOB)
                continue;
        }

        {
            DM_PROFILE("JobThreadProcess");
            ProcessOneJob(ctx, hjob);
        }
    }
}
#endif

static void ProcessFinishedJobs(HJobContext context, jc::RingBuffer<HJob>& items)