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