Searched refs:new_worker (Results 1 – 4 of 4) sorted by relevance
22 struct new_worker : public worker_interface struct25 typedef new_worker this_type; argument29 new_worker(const this_type&);68 virtual ~new_worker() in ~new_worker() argument72 explicit new_worker(std::shared_ptr<new_worker_state> ws) in new_worker() argument77 new_worker(composite_subscription cs, thread_factory& tf) in new_worker() argument95 queue_type::ensure(std::make_shared<new_worker>(keepAlive)); in new_worker()169 return worker(cs, std::make_shared<new_worker>(cs, factory)); in create_worker()
483 bool new_worker = false; in CreateTaskRunnerWithTraitsImpl() local499 new_worker = true; in CreateTaskRunnerWithTraitsImpl()504 if (new_worker && started) in CreateTaskRunnerWithTraitsImpl()
839 SchedulerWorker* new_worker = in MaintainAtLeastOneIdleWorkerLockRequired() local841 if (new_worker) in MaintainAtLeastOneIdleWorkerLockRequired()842 idle_workers_stack_.Push(new_worker); in MaintainAtLeastOneIdleWorkerLockRequired()
5145 kmp_info_t *new_worker = __kmp_allocate_thread(root, team, f); in __kmp_allocate_team() local5146 KMP_DEBUG_ASSERT(new_worker); in __kmp_allocate_team()5147 team->t.t_threads[f] = new_worker; in __kmp_allocate_team()5158 kmp_balign_t *balign = new_worker->th.th_bar; in __kmp_allocate_team()