Method ClearLPQueue

library/cpp/threading/local_executor/local_executor.cpp:334–347

}

void NPar::TLocalExecutor::ClearLPQueue() {
    for (bool cont = true; cont;) {
        cont = false;
        TSingleJob job;
        while (Impl_->LowJobQueue.Dequeue(&job)) {
            --Impl_->LPQueueSize;
            cont = true;
        }
        while (Impl_->MedJobQueue.Dequeue(&job)) {
            --Impl_->MPQueueSize;
            cont = true;
        }
    }
}

int NPar::TLocalExecutor::GetQueueSize() const noexcept {
    return Impl_->QueueSize.load();