ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::schedulers::new_thread Class Reference

Scheduler which schedules invoking of schedulables to another thread via queueing tasks with priority to time_point and order. More...

#include <new_thread.hpp>

Classes

class  worker_strategy
 

Static Public Member Functions

static rpp::schedulers::worker< worker_strategycreate_worker ()
 

Detailed Description

Scheduler which schedules invoking of schedulables to another thread via queueing tasks with priority to time_point and order.

Warning
Creates new thread for each "create_worker" call, but not for each schedule

This scheduler useful when we want to have separate thread for processing starting from some timepoint.

Examples
as_blocking.cpp, connect.cpp, delay.cpp, observe_on.cpp, subscribe_on.cpp, and timeout.cpp.

The documentation for this class was generated from the following file: