The thread system context, for blocking operations.
More...
#include <system_context_thread.h>
|
| system_context_thread_t () noexcept |
| constructs thread system context
|
|
virtual void | run () noexcept |
| invokes blocking execution of the supervisor
|
|
void | check () noexcept |
| checks for messages from external threads and fires expired timers
|
|
template<typename Supervisor = supervisor_t> |
auto | create_supervisor () |
| returns builder for root supervisor
|
|
supervisor_ptr_t | get_supervisor () noexcept |
| returns root supervisor
|
|
| system_context_t (const system_context_t &)=delete |
|
| system_context_t (system_context_t &&)=delete |
|
virtual void | on_error (actor_base_t *actor, const extended_error_ptr_t &ec) noexcept |
| fatal error handler
|
|
virtual std::string | identity () noexcept |
| identifies the context.
|
|
template<typename T > |
auto & | access () noexcept |
| generic non-public fields accessor
|
|
const message_stringifier_t & | get_stringifier () |
| returns the default stringifier
|
|
|
using | clock_t = std::chrono::steady_clock |
| an alias for monotonic clock
|
|
using | list_t = std::list< deadline_info_t > |
| ordered list of deadline infos (type)
|
|
|
void | update_time () noexcept |
| fires handlers for expired timers
|
|
void | start_timer (const pt::time_duration &interval, timer_handler_base_t &handler) noexcept |
| start timer implementation
|
|
void | cancel_timer (request_id_t timer_id) noexcept |
| cancel timer implementation
|
|
virtual message_stringifier_ptr_t | make_stringifier () const noexcept |
| constructs message stringifier
|
|
|
std::mutex | mutex |
| mutex for inbound queue
|
|
std::condition_variable | cv |
| cv for notifying about pushing messages into inbound queue
|
|
clock_t::time_point | now |
| current time
|
|
list_t | timer_nodes |
| ordered list of deadline infos
|
|
bool | intercepting = false |
| whether the context is intercepting blocking (I/O) handler
|
|
|
struct | supervisor_thread_t |
|
The thread system context, for blocking operations.
◆ run()
virtual void rotor::thread::system_context_thread_t::run |
( |
| ) |
|
|
virtualnoexcept |
invokes blocking execution of the supervisor
It blocks until root supervisor shuts down.
The documentation for this struct was generated from the following file: