1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 |
- // 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
|