Waiting for multiple futures?

by

Thread support in C++11 was just a first pass, and while std::future rocks, it does not support multiple waiting as yet.

You can fake it relatively inefficiently, however. You end up creating a helper thread for each std::future (ouch, very expensive), then gathering their “this future is ready” into a synchronized many-producer single-consumer message queue, then setting up a consumer task that dispatches the fact that a given std::future is ready.

The std::future in this system doesn’t add much functionality, and having tasks that directly state that they are ready and sticks their result into the above queue would be more efficient. If you go this route, you could write wrapper that match the pattern of std::async or std::thread, and return a std::future like object that represents a queue message. This basically involves reimplementing a chunk of the the concurrency library.

If you want to stay with std::future, you could create shared_futures, and have each dependent task depend on the set of shared_futures: ie, do it without a central scheduler. This doesn’t permit things like abort/shutdown messages, which I consider essential for a robust multi threaded task system.

Finally, you can wait for C++2x, or whenever the concurrency TS is folded into the standard, to solve the problem for you.

More Related Contents:

  1. C++11 introduced a standardized memory model. What does it mean? And how is it going to affect C++ programming?
  2. How do I terminate a thread in C++11?
  3. Concurrency: Atomic and volatile in C++11 memory model
  4. Passing object by reference to std::thread in C++11
  5. Why don’t compilers merge redundant std::atomic writes?
  6. What are the correct link options to use std::thread in GCC under linux?
  7. Why is the destructor of a future returned from `std::async` blocking?
  8. std::thread pass by reference calls copy constructor
  9. C++11 thread-safe queue
  10. How to use std::async on a member function?
  11. How to give priority to privileged thread in mutex locking?
  12. Which std::async implementations use thread pools?
  13. C++0x thread interruption
  14. What causes runtime error message: std::system_error – operation not permitted, including mult-threading? [duplicate]
  15. What is the difference between packaged_task and async
  16. Get the status of a std::future
  17. std::thread is not a member of namespace std using Eclipse Kepler MinGW
  18. Is it smart to replace boost::thread and boost::mutex with c++11 equivalents?
  19. C++11 STL containers and thread safety
  20. Can I use std::async without waiting for the future limitation?
  21. C++ terminate called without an active exception
  22. What is different between join() and detach() for multi threading in C++?
  23. std::thread error (thread not member of std)
  24. Double-Checked Lock Singleton in C++11
  25. I want to kill a std::thread using its thread object? [duplicate]
  26. thread safety of MPI send using threads created with std::async
  27. GCC std::thread not found in namespace std
  28. C++11 Implementation of Spinlock using header “
  29. About thread-safety of weak_ptr
  30. Why does this simple std::thread example not work?

Leave a Comment