123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149 |
- #ifndef BOOST_ASIO_DETAIL_WINRT_TIMER_SCHEDULER_HPP
- #define BOOST_ASIO_DETAIL_WINRT_TIMER_SCHEDULER_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif
- #include <boost/asio/detail/config.hpp>
- #if defined(BOOST_ASIO_WINDOWS_RUNTIME)
- #include <cstddef>
- #include <boost/asio/detail/event.hpp>
- #include <boost/asio/detail/limits.hpp>
- #include <boost/asio/detail/mutex.hpp>
- #include <boost/asio/detail/op_queue.hpp>
- #include <boost/asio/detail/thread.hpp>
- #include <boost/asio/detail/timer_queue_base.hpp>
- #include <boost/asio/detail/timer_queue_set.hpp>
- #include <boost/asio/detail/wait_op.hpp>
- #include <boost/asio/execution_context.hpp>
- #if defined(BOOST_ASIO_HAS_IOCP)
- # include <boost/asio/detail/win_iocp_io_context.hpp>
- #else
- # include <boost/asio/detail/scheduler.hpp>
- #endif
- #if defined(BOOST_ASIO_HAS_IOCP)
- # include <boost/asio/detail/thread.hpp>
- #endif
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- namespace detail {
- class winrt_timer_scheduler
- : public execution_context_service_base<winrt_timer_scheduler>
- {
- public:
-
- BOOST_ASIO_DECL winrt_timer_scheduler(execution_context& context);
-
- BOOST_ASIO_DECL ~winrt_timer_scheduler();
-
- BOOST_ASIO_DECL void shutdown();
-
- BOOST_ASIO_DECL void notify_fork(execution_context::fork_event fork_ev);
-
- BOOST_ASIO_DECL void init_task();
-
- template <typename Time_Traits>
- void add_timer_queue(timer_queue<Time_Traits>& queue);
-
- template <typename Time_Traits>
- void remove_timer_queue(timer_queue<Time_Traits>& queue);
-
-
- template <typename Time_Traits>
- void schedule_timer(timer_queue<Time_Traits>& queue,
- const typename Time_Traits::time_type& time,
- typename timer_queue<Time_Traits>::per_timer_data& timer, wait_op* op);
-
-
- template <typename Time_Traits>
- std::size_t cancel_timer(timer_queue<Time_Traits>& queue,
- typename timer_queue<Time_Traits>::per_timer_data& timer,
- std::size_t max_cancelled = (std::numeric_limits<std::size_t>::max)());
-
- template <typename Time_Traits>
- void move_timer(timer_queue<Time_Traits>& queue,
- typename timer_queue<Time_Traits>::per_timer_data& to,
- typename timer_queue<Time_Traits>::per_timer_data& from);
- private:
-
- BOOST_ASIO_DECL void run_thread();
-
- BOOST_ASIO_DECL static void call_run_thread(winrt_timer_scheduler* reactor);
-
- BOOST_ASIO_DECL void do_add_timer_queue(timer_queue_base& queue);
-
- BOOST_ASIO_DECL void do_remove_timer_queue(timer_queue_base& queue);
-
- #if defined(BOOST_ASIO_HAS_IOCP)
- typedef class win_iocp_io_context scheduler_impl;
- #else
- typedef class scheduler scheduler_impl;
- #endif
- scheduler_impl& scheduler_;
-
- boost::asio::detail::mutex mutex_;
-
- boost::asio::detail::event event_;
-
- timer_queue_set timer_queues_;
-
- boost::asio::detail::thread* thread_;
-
- bool stop_thread_;
-
- bool shutdown_;
- };
- }
- }
- }
- #include <boost/asio/detail/pop_options.hpp>
- #include <boost/asio/detail/impl/winrt_timer_scheduler.hpp>
- #if defined(BOOST_ASIO_HEADER_ONLY)
- # include <boost/asio/detail/impl/winrt_timer_scheduler.ipp>
- #endif
- #endif
- #endif
|