Method ExecTasks

catboost/libs/helpers/resource_constrained_executor.cpp:49–77

    }

    void TResourceConstrainedExecutor::ExecTasks() {
        while (!Queue.empty()) {
            TVector<std::function<void()>> tasks;

            TResourceUnit freeResource = ResourceQuota;

            while (true) {
                auto it = Queue.lower_bound(freeResource);
                if (it == Queue.end()) {
                    break;
                }

                freeResource -= it->first;
                tasks.push_back(std::move(it->second));
                Queue.erase(it);
            };

            if (LenientMode && tasks.empty()) {
                // execute at least one task even if it requests more than ResourceQuota
                auto it = Queue.begin();
                tasks.push_back(std::move(it->second));
                Queue.erase(it);
            } else {
                Y_ASSERT(!tasks.empty());
            }

            ExecuteTasksInParallel(&tasks, &LocalExecutor);
        }
    }
}