Home
last modified time | relevance | path

Searched refs:thread_dispatcher (Results 1 – 9 of 9) sorted by relevance

/oneTBB/src/tbb/
H A Dthread_dispatcher.cpp24 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()
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()
99 void thread_dispatcher::insert_client(thread_dispatcher_client& client) { in insert_client()
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()
202 void thread_dispatcher::acknowledge_close_connection() { in acknowledge_close_connection()
206 ::rml::job* thread_dispatcher::create_one_job() { in create_one_job()
[all …]
H A Dthread_request_serializer.h40 thread_request_serializer(thread_dispatcher& td, int soft_limit);
49 thread_dispatcher& my_thread_dispatcher;
63 thread_request_serializer_proxy(thread_dispatcher& td, int soft_limit);
H A Dthread_dispatcher.h37 class thread_dispatcher : no_copy, rml::tbb_client {
41 thread_dispatcher(threading_control& tc, unsigned hard_limit, std::size_t stack_size);
42 ~thread_dispatcher();
H A Dthreading_control.h79 …static cache_aligned_unique_ptr<thread_dispatcher> make_thread_dispatcher(threading_control& contr…
85 cache_aligned_unique_ptr<thread_dispatcher> my_thread_dispatcher{nullptr};
134 friend class thread_dispatcher; variable
H A Dthread_request_serializer.cpp24 thread_request_serializer::thread_request_serializer(thread_dispatcher& td, int soft_limit) in thread_request_serializer()
79 thread_request_serializer_proxy::thread_request_serializer_proxy(thread_dispatcher& td, int soft_li… in thread_request_serializer_proxy()
H A Dthreading_control.cpp74 cache_aligned_unique_ptr<thread_dispatcher> threading_control_impl::make_thread_dispatcher(threadin… in make_thread_dispatcher()
80 cache_aligned_unique_ptr<thread_dispatcher> td = in make_thread_dispatcher()
81 make_cache_aligned_unique<thread_dispatcher>(tc, workers_hard_limit, stack_size); in make_thread_dispatcher()
H A Dgovernor.h50 friend class thread_dispatcher; variable
H A DCMakeLists.txt43 thread_dispatcher.cpp
H A Dgovernor.cpp114 return ((const thread_dispatcher&)client).must_join_workers(); in does_client_join_workers()