Home
last modified time | relevance | path

Searched defs:new_worker_state (Results 1 – 1 of 1) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-newthread.hpp31 struct new_worker_state : public std::enable_shared_from_this<new_worker_state> struct
34 typename clock_type::time_point> queue_item_time;
36 typedef queue_item_time::item_type item_type;
38 virtual ~new_worker_state() in ~new_worker_state()
42 explicit new_worker_state(composite_subscription cs) in new_worker_state() function
47 composite_subscription lifetime;
48 mutable std::mutex lock;
49 mutable std::condition_variable wake;
50 mutable queue_item_time q;
51 std::thread worker;
[all …]