How to create a thread pool using boost in C++?

by

The process is pretty simple. First create an asio::io_service and a thread_group. Fill the thread_group with threads linked to the io_service. Assign tasks to the threads using the boost::bind function.

To stop the threads (usually when you are exiting your program) just stop the io_service and join all threads.

You should only need these headers:

#include <boost/asio/io_service.hpp>
#include <boost/bind.hpp>
#include <boost/thread/thread.hpp>

here is an example: 

/*
 * Create an asio::io_service and a thread_group (through pool in essence)
 */
boost::asio::io_service ioService;
boost::thread_group threadpool;


/*
 * This will start the ioService processing loop. All tasks 
 * assigned with ioService.post() will start executing. 
 */
boost::asio::io_service::work work(ioService);

/*
 * This will add 2 threads to the thread pool. (You could just put it in a for loop)
 */
threadpool.create_thread(
    boost::bind(&boost::asio::io_service::run, &ioService)
);
threadpool.create_thread(
    boost::bind(&boost::asio::io_service::run, &ioService)
);

/*
 * This will assign tasks to the thread pool. 
 * More about boost::bind: "http://www.boost.org/doc/libs/1_54_0/libs/bind/bind.html#with_functions"
 */
ioService.post(boost::bind(myTask, "Hello World!"));
ioService.post(boost::bind(clearCache, "./cache"));
ioService.post(boost::bind(getSocialUpdates, "twitter,gmail,facebook,tumblr,reddit"));

/*
 * This will stop the ioService processing loop. Any tasks
 * you add behind this point will not execute.
*/
ioService.stop();

/*
 * Will wait till all the threads in the thread pool are finished with 
 * their assigned tasks and 'join' them. Just assume the threads inside
 * the threadpool will be destroyed by this method.
 */
threadpool.join_all();

Source: Recipes < Asio

More Related Contents:

  1. c++ work queues with blocking
  2. C++ Thread Pool [closed]
  3. Creating a thread pool using boost
  4. Why do I need strand per connection when using boost::asio?
  5. Example for boost shared_mutex (multiple reads/one write)?
  6. What is the usefulness of `enable_shared_from_this`?
  7. Should the exception thrown by boost::asio::io_service::run() be caught?
  8. Best documentation for Boost:asio?
  9. How to set a timeout on blocking sockets in boost asio?
  10. boost asio ssl async_shutdown always finishes with an error?
  11. Cancelling boost asio deadline timer safely
  12. Boost async_* functions and shared_ptr’s
  13. Thread pool using boost asio
  14. Boost ASIO streambuf
  15. Copy a streambuf’s contents to a string
  16. Boost::asio – how to interrupt a blocked tcp server thread?
  17. C++ Boost ASIO simple periodic timer?
  18. When must you pass io_context to boost::asio::spawn? (C++)
  19. BOOST ASIO – How to write console server
  20. Exception running boost asio ssl example
  21. Boost.Asio as header-only
  22. boost::asio with boost::unique_future
  23. asio How to change the executor inside an awaitable?
  24. Strange exception throw – assign: Operation not permitted
  25. Why does Boost.Asio not support an event-based interface?
  26. How to link C++ program with Boost using CMake
  27. Which Boost features overlap with C++11?
  28. boost::flat_map and its performance compared to map and unordered_map
  29. how provide a vertex_index property for my graph
  30. Why does nvcc fails to compile a CUDA file with boost::spirit?

Leave a Comment