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()42 explicit new_worker_state(composite_subscription cs) in new_worker_state() function47 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 …]