Searched defs:new_worker_state (Results 1 – 1 of 1) sorted by relevance
31 struct new_worker_state : public std::enable_shared_from_this<new_worker_state> struct34 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()52 explicit new_worker_state(composite_subscription cs) in new_worker_state() argument57 composite_subscription lifetime;58 mutable std::mutex lock;59 mutable std::condition_variable wake;60 mutable queue_item_time q;61 std::thread worker;[all …]