Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- FutureVec.emplace_back(msg.get_future());
- thread_pool.submit(msg);
- auto it = FutureVec.begin();
- std::this_thread::sleep_for(std::chrono::seconds{1});
- while(!FutureVec.empty())
- {
- if(it->valid())
- {
- std::cout << it->get() << std::endl;
- FutureVec.erase(it);
- if(it == FutureVec.end())
- {
- break;
- }
- continue;
- }
- ++it;
- if(it == FutureVec.end())
- {
- it = FutureVec.begin();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement