| // 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_SCHEDULING_ADAPTOR_HPP |
| #define BOOST_THREAD_EXECUTORS_SCHEDULING_ADAPTOR_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> |
| |
| #if defined(BOOST_MSVC) |
| # pragma warning(push) |
| # pragma warning(disable: 4355) // 'this' : used in base member initializer list |
| #endif |
| |
| namespace boost |
| { |
| namespace executors |
| { |
| |
| template <typename Executor> |
| class scheduling_adaptor : public detail::scheduled_executor_base<> |
| { |
| private: |
| Executor& _exec; |
| thread _scheduler; |
| public: |
| |
| scheduling_adaptor(Executor& ex) |
| : super(), |
| _exec(ex), |
| _scheduler(&super::loop, this) {} |
| |
| ~scheduling_adaptor() |
| { |
| this->close(); |
| _scheduler.interrupt(); |
| _scheduler.join(); |
| } |
| |
| Executor& underlying_executor() |
| { |
| return _exec; |
| } |
| |
| private: |
| typedef detail::scheduled_executor_base<> super; |
| }; //end class |
| |
| } //end executors |
| |
| using executors::scheduling_adaptor; |
| |
| } //end boost |
| |
| #if defined(BOOST_MSVC) |
| # pragma warning(pop) |
| #endif |
| |
| #endif |
| #endif |