| // Copyright (C) 2014 Ian Forbed |
| // Copyright (C) 2014 Vicente J. Botet Escriba |
| // |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) |
| // |
| |
| #ifndef BOOST_THREAD_EXECUTORS_SCHEDULED_THREAD_POOL_HPP |
| #define BOOST_THREAD_EXECUTORS_SCHEDULED_THREAD_POOL_HPP |
| |
| #include <boost/thread/detail/config.hpp> |
| #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION && defined BOOST_THREAD_PROVIDES_EXECUTORS && defined BOOST_THREAD_USES_MOVE |
| |
| #include <boost/thread/executors/detail/scheduled_executor_base.hpp> |
| |
| namespace boost |
| { |
| namespace executors |
| { |
| |
| class scheduled_thread_pool : public detail::scheduled_executor_base<> |
| { |
| private: |
| thread_group _workers; |
| public: |
| |
| scheduled_thread_pool(size_t num_threads) : super() |
| { |
| for(size_t i = 0; i < num_threads; i++) |
| { |
| _workers.create_thread(bind(&super::loop, this)); |
| } |
| } |
| |
| ~scheduled_thread_pool() |
| { |
| this->close(); |
| _workers.interrupt_all(); |
| _workers.join_all(); |
| } |
| |
| private: |
| typedef detail::scheduled_executor_base<> super; |
| }; //end class |
| |
| } //end executors namespace |
| |
| using executors::scheduled_thread_pool; |
| |
| } //end boost |
| #endif |
| #endif |
| |