libs/corosio/include/boost/corosio/detail/scheduler.hpp

100.0% Lines (1/1) 100.0% Functions (1/1) -% Branches (0/0)

Line	Hits	Source Code
1		//
2		// Copyright (c) 2025 Vinnie Falco (vinnie dot falco at gmail dot com)
3		//
4		// Distributed under the Boost Software License, Version 1.0. (See accompanying
5		// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6		//
7		// Official repository: https://github.com/cppalliance/corosio
8		//
9
10		#ifndef BOOST_COROSIO_DETAIL_SCHEDULER_HPP
11		#define BOOST_COROSIO_DETAIL_SCHEDULER_HPP
12
13		#include <boost/corosio/detail/config.hpp>
14		#include <boost/capy/coro.hpp>
15
16		#include <cstddef>
17
18		namespace boost::corosio::detail {
19
20		class scheduler_op;
21
22		struct scheduler
23		{
24	304	virtual ~scheduler() = default;
25		virtual void post(capy::coro) const = 0;
26		virtual void post(scheduler_op*) const = 0;
27
28		/** Notify scheduler of pending work (for executor use).
29		When the count reaches zero, the scheduler stops.
30		*/
31		virtual void on_work_started() noexcept = 0;
32		virtual void on_work_finished() noexcept = 0;
33
34		/** Notify scheduler of pending I/O work (for services use).
35		Unlike on_work_finished, work_finished does not stop the scheduler
36		when the count reaches zero - it only wakes blocked threads.
37		*/
38		virtual void work_started() const noexcept = 0;
39		virtual void work_finished() const noexcept = 0;
40
41		virtual bool running_in_this_thread() const noexcept = 0;
42		virtual void stop() = 0;
43		virtual bool stopped() const noexcept = 0;
44		virtual void restart() = 0;
45		virtual std::size_t run() = 0;
46		virtual std::size_t run_one() = 0;
47		virtual std::size_t wait_one(long usec) = 0;
48		virtual std::size_t poll() = 0;
49		virtual std::size_t poll_one() = 0;
50		};
51
52		} // namespace boost::corosio::detail
53
54		#endif
55