Method Dispatch

Source/Engine/Threading/JobSystem.cpp:285–331

}

int64 JobSystem::Dispatch(const Function<void(int32)>& job, int32 jobCount)
{
    if (jobCount <= 0)
        return 0;
    PROFILE_CPU();
#if JOB_SYSTEM_ENABLED
    while (Platform::InterlockedIncrement(&JobContextsCount) >= JobContextsSize)
    {
        // Too many jobs in flight, wait for some to complete to free up contexts
        PROFILE_CPU_NAMED("JOB SYSTEM OVERFLOW");
        ZoneColor(TracyWaitZoneColor);
        Platform::InterlockedDecrement(&JobContextsCount);
        Platform::Sleep(1);
    }

    // Get a new label
    const int64 label = Platform::InterlockedIncrement(&JobLabel);

    // Build job
    JobContext& context = JobContexts[GET_CONTEXT_INDEX(label)];
    context.Job = job;
    context.JobIndex = 0;
    context.JobsLeft = jobCount;
    context.JobLabel = label;
    context.DependantsCount = 0;
    context.DependenciesLeft = 0;
    context.JobsCount = jobCount;
    context.Dependants.Clear();

    // Move the job queue forward
    Platform::InterlockedIncrement(&JobEndLabel);

    if (JobStartingOnDispatch)
    {
        if (jobCount == 1)
            JobsSignal.NotifyOne();
        else
            JobsSignal.NotifyAll();
    }

    return label;
#else
    for (int32 i = 0; i < jobCount; i++)
        job(i);
    return 0;
#endif
}

int64 JobSystem::Dispatch(const Function<void(int32)>& job, Span<int64> dependencies, int32 jobCount)
{