Lines Matching refs:thread_dispatcher
24 thread_dispatcher::thread_dispatcher(threading_control& tc, unsigned hard_limit, std::size_t stack_… in thread_dispatcher() function in tbb::detail::r1::thread_dispatcher
33 thread_dispatcher::~thread_dispatcher() { in ~thread_dispatcher()
37 thread_dispatcher_client* thread_dispatcher::select_next_client(thread_dispatcher_client* hint) { in select_next_client()
52 thread_dispatcher_client* thread_dispatcher::create_client(arena& a) { in create_client()
57 void thread_dispatcher::register_client(thread_dispatcher_client* client) { in register_client()
62 bool thread_dispatcher::try_unregister_client(thread_dispatcher_client* client, std::uint64_t aba_e… in try_unregister_client()
93 void thread_dispatcher::destroy_client(thread_dispatcher_client* client) { in destroy_client()
99 void thread_dispatcher::insert_client(thread_dispatcher_client& client) { in insert_client()
108 void thread_dispatcher::remove_client(thread_dispatcher_client& client) { in remove_client()
118 bool thread_dispatcher::is_client_alive(thread_dispatcher_client* client) { in is_client_alive()
134 thread_dispatcher_client* thread_dispatcher::client_in_need(client_list_type* clients, thread_dispa… in client_in_need()
159 thread_dispatcher_client* thread_dispatcher::client_in_need(thread_dispatcher_client* prev) { in client_in_need()
167 void thread_dispatcher::adjust_job_count_estimate(int delta) { in adjust_job_count_estimate()
171 void thread_dispatcher::release(bool blocking_terminate) { in release()
176 void thread_dispatcher::process(job& j) { in process()
197 bool thread_dispatcher::must_join_workers() const { return my_join_workers; } in must_join_workers()
200 std::size_t thread_dispatcher::worker_stack_size() const { return my_stack_size; } in worker_stack_size()
202 void thread_dispatcher::acknowledge_close_connection() { in acknowledge_close_connection()
206 ::rml::job* thread_dispatcher::create_one_job() { in create_one_job()
217 void thread_dispatcher::cleanup(job& j) { in cleanup()