Lines Matching refs:threading_control
74 …unique_ptr<thread_dispatcher> threading_control_impl::make_thread_dispatcher(threading_control& tc, in make_thread_dispatcher()
91 threading_control_impl::threading_control_impl(threading_control* tc) { in threading_control_impl()
177 void threading_control::add_ref(bool is_public) { in add_ref()
184 bool threading_control::remove_ref(bool is_public) { in remove_ref()
200 threading_control* threading_control::get_threading_control(bool is_public) { in get_threading_control()
201 threading_control* control = g_threading_control; in get_threading_control()
209 threading_control* threading_control::create_threading_control() { in create_threading_control()
213 threading_control* thr_control{ nullptr }; in create_threading_control()
219 …thr_control = new (cache_aligned_allocate(sizeof(threading_control))) threading_control(/*public_… in create_threading_control()
242 void threading_control::destroy () { in destroy()
248 void threading_control::wait_last_reference(global_mutex_type::scoped_lock& lock) { in wait_last_reference()
265 bool threading_control::release(bool is_public, bool blocking_terminate) { in release()
285 threading_control::threading_control(unsigned public_ref, unsigned ref) : my_public_ref_count(publi… in threading_control() function in tbb::detail::r1::threading_control
288 threading_control* threading_control::register_public_reference() { in register_public_reference()
289 threading_control* control{nullptr}; in register_public_reference()
301 bool threading_control::unregister_public_reference(bool blocking_terminate) { in unregister_public_reference()
307 threading_control_client threading_control::create_client(arena& a) { in create_client()
316 void threading_control::publish_client(threading_control_client client, d1::constraints& constraint… in publish_client()
320 threading_control::client_snapshot threading_control::prepare_client_destruction(threading_control_… in prepare_client_destruction()
324 bool threading_control::try_destroy_client(threading_control::client_snapshot deleter) { in try_destroy_client()
332 void threading_control::set_active_num_workers(unsigned soft_limit) { in set_active_num_workers()
333 threading_control* thr_control = get_threading_control(/*public = */ false); in set_active_num_workers()
340 bool threading_control::is_present() { in is_present()
345 bool threading_control::register_lifetime_control() { in register_lifetime_control()
350 bool threading_control::unregister_lifetime_control(bool blocking_terminate) { in unregister_lifetime_control()
351 threading_control* thr_control{nullptr}; in unregister_lifetime_control()
365 void threading_control::register_thread(thread_data& td) { in register_thread()
369 void threading_control::unregister_thread(thread_data& td) { in unregister_thread()
373 void threading_control::propagate_task_group_state(std::atomic<uint32_t> d1::task_group_context::*m… in propagate_task_group_state()
379 std::size_t threading_control::worker_stack_size() { in worker_stack_size()
383 unsigned threading_control::max_num_workers() { in max_num_workers()
388 void threading_control::adjust_demand(threading_control_client client, int mandatory_delta, int wor… in adjust_demand()
392 thread_control_monitor& threading_control::get_waiting_threads_monitor() { in get_waiting_threads_monitor()