Method LaunchRange

library/cpp/threading/local_executor/local_executor.cpp:225–236

}

void NPar::TLocalExecutor::TImpl::LaunchRange(TIntrusivePtr<TLocalRangeExecutor> execRange,
                                              int queueSizeLimit,
                                              std::atomic<int>* queueSize,
                                              TLockFreeQueue<TSingleJob>* jobQueue) {
    int count = Min<int>(ThreadCount + 1, execRange->GetRangeSize());
    if (queueSizeLimit >= 0 && queueSize->load() >= queueSizeLimit) {
        return;
    }
    queueSize->fetch_add(count);
    jobQueue->EnqueueAll(TVector<TSingleJob>{size_t(count), TSingleJob(std::move(execRange), 0)});
    HasJob.Signal();
}

NPar::TLocalExecutor::TLocalExecutor()
    : Impl_{MakeHolder<TImpl>()} {