Searched refs: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> struct38 virtual ~new_worker_state() in ~new_worker_state() argument52 explicit new_worker_state(composite_subscription cs) in new_worker_state() function65 std::shared_ptr<new_worker_state> state;72 explicit new_worker(std::shared_ptr<new_worker_state> ws) in new_worker()78 : state(std::make_shared<new_worker_state>(cs)) in new_worker()85 keepAlive->q = new_worker_state::queue_item_time{}; in new_worker()140 state->q.push(new_worker_state::item_type(when, scbl)); in schedule()