Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 13 of 13) sorted by relevance

/oneTBB/src/tbb/
H A Dobserver_proxy.h54 void do_notify_entry_observers( observer_proxy*& last, bool worker );
57 void do_notify_exit_observers( observer_proxy* last, bool worker );
85 inline void notify_entry_observers( observer_proxy*& last, bool worker );
88 inline void notify_exit_observers( observer_proxy*& last, bool worker );
132 void observer_list::notify_entry_observers(observer_proxy*& last, bool worker) { in notify_entry_observers() argument
135 do_notify_entry_observers(last, worker); in notify_entry_observers()
138 void observer_list::notify_exit_observers( observer_proxy*& last, bool worker ) { in notify_exit_observers() argument
143 do_notify_exit_observers( last, worker ); in notify_exit_observers()
H A Dobserver_proxy.cpp146 void observer_list::do_notify_entry_observers(observer_proxy*& last, bool worker) { in do_notify_entry_observers() argument
199 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
207 void observer_list::do_notify_exit_observers(observer_proxy* last, bool worker) { in do_notify_exit_observers() argument
253 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
/oneTBB/python/tbb/
H A D__init__.py70 from multiprocessing.pool import worker
71 worker(inqueue, outqueue, initializer, initargs, maxtasks)
112 from multiprocessing.pool import worker
113 worker(inqueue, outqueue, initializer, initargs, maxtasks, wrap_exception)
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_Scheduler_Init.rst38 limits the total number of oneTBB worker threads
120 to set the stack size for oneTBB worker threads:
128 // Set 16 MB of the stack size for oneTBB worker threads.
145 allows waiting for oneTBB worker threads completion:
/oneTBB/doc/main/tbb_userguide/
H A Dparallel_reduce.rst93 When a worker thread is available, as decided by the task scheduler,
95 subtask for the worker. When the subtask completes, ``parallel_reduce``
98 happens when a worker is available:
117 If a worker is not available, the second half of the iteration is
H A DInitializing_and_Terminating_the_Library.rst16 until all worker threads implicitly created by the library have completed.
H A DWhen_Not_to_Use_Queues.rst29 threading is implicit, it optimizes use of worker threads so that they
H A DFloating_Point_Settings.rst11 By default, worker threads use floating-point settings obtained during the initialization of a ``ta…
H A Dparallel_for_os.rst69 copy (or copies) for each worker thread. It also invokes the destructor
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DGUI_Thread.rst67 The semantics of ``enqueue`` cause the task to eventually run on a worker thread
139 to a worker thread and immediately returns.
147 When a worker finishes the long computation, it pushes the result
192 worker while the GUI thread was holding a lock on the mutex, and vice
/oneTBB/doc/main/intro/
H A Dlimitations.rst46 …round the issue, consider using ``task_scheduler_handle`` to join oneTBB worker threads before usi…
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp520 void on_scheduler_exit(bool worker) override { in on_scheduler_exit()
521 if (worker) { in on_scheduler_exit()
1358 void on_scheduler_entry(bool worker) override { in on_scheduler_entry()
1359 if (worker) { in on_scheduler_entry()
1369 void on_scheduler_exit(bool worker) override { in on_scheduler_exit()
1370 if (worker) { in on_scheduler_exit()
H A Dtest_eh_algorithms.cpp1183 ParForEachWorker<body_to_cancel, Iterator> worker(ctx); in TestCancelation1_parallel_for_each() local
1186 tg.run( worker ); in TestCancelation1_parallel_for_each()