diff options
Diffstat (limited to 'boost/thread/executors/detail/scheduled_executor_base.hpp')
-rw-r--r-- | boost/thread/executors/detail/scheduled_executor_base.hpp | 66 |
1 files changed, 66 insertions, 0 deletions
diff --git a/boost/thread/executors/detail/scheduled_executor_base.hpp b/boost/thread/executors/detail/scheduled_executor_base.hpp new file mode 100644 index 0000000000..ec0038f7e3 --- /dev/null +++ b/boost/thread/executors/detail/scheduled_executor_base.hpp @@ -0,0 +1,66 @@ +// Copyright (C) 2014 Ian Forbed +// Copyright (C) 2014-2015 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_DETAIL_SCHEDULED_EXECUTOR_BASE_HPP +#define BOOST_THREAD_EXECUTORS_DETAIL_SCHEDULED_EXECUTOR_BASE_HPP + +#include <boost/thread/concurrent_queues/sync_timed_queue.hpp> +#include <boost/thread/executors/detail/priority_executor_base.hpp> +#include <boost/thread/executors/work.hpp> +#include <boost/thread/thread.hpp> + +#include <boost/atomic.hpp> +#include <boost/function.hpp> + +#include <boost/config/abi_prefix.hpp> + +namespace boost +{ +namespace executors +{ +namespace detail +{ + template <class Clock=chrono::steady_clock> + class scheduled_executor_base : public priority_executor_base<concurrent::sync_timed_queue<executors::work_pq, Clock > > + { + public: + typedef executors::work_pq work; + typedef Clock clock; + typedef typename clock::duration duration; + typedef typename clock::time_point time_point; + protected: + + scheduled_executor_base() {} + public: + + ~scheduled_executor_base() + { + if(! this->closed()) + { + this->close(); + } + } + + void submit_at(work w, const time_point& tp) + { + this->_workq.push(boost::move(w), tp); + } + + void submit_after(work w, const duration& dura) + { + this->_workq.push(boost::move(w), dura+clock::now()); + } + + }; //end class + +} //end detail namespace +} //end executors namespace +} //end boost namespace + +#include <boost/config/abi_suffix.hpp> + +#endif |