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 Referencefinal

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

#include <new_thread_scheduler.hpp>

Inheritance diagram for rpp::schedulers::new_thread:
rpp::schedulers::details::scheduler_tag

Classes

class  worker_strategy
 

Static Public Member Functions

static auto create_worker (const rpp::composite_subscription &sub=composite_subscription{})
 

Detailed Description

scheduler which schedules execution of schedulables via queueing tasks to another thread with priority to time_point and order

Warning
Creates new thread for each "create_worker" call. Any scheduled task will be queued to created thread for execution with respect to time_point and number of task
Examples
delay.cpp, from.cpp, just.cpp, observe_on.cpp, subscribe_on.cpp, and timeout.cpp.

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