Method ForEachWaitAll

preempt/src/xqueue/xqueue.cpp:89–101

}

XResult XQueueManager::ForEachWaitAll()
{
    std::list<std::shared_ptr<XQueueWaitAllCommand>> wait_cmds;
    std::unique_lock<std::mutex> lock(mtx_);
    for (auto it : xqs_) {
        auto wait_cmd = it.second->SubmitWaitAll();
        if (wait_cmd == nullptr) return kXSchedErrorUnknown;
        wait_cmds.push_back(wait_cmd);
    }
    lock.unlock();
    for (auto &cmd : wait_cmds) cmd->Wait();
    return kXSchedSuccess;
}

XResult XQueueManager::ForEach(std::function<XResult(std::shared_ptr<XQueue>)> func)
{