Home
last modified time | relevance | path

Searched refs:join (Results 1 – 25 of 52) sorted by relevance

123

/oneTBB/python/
H A Dsetup.py61 include_dirs=[os.path.join(tbb_root, 'include')] if not use_compiler_tbb else [],
63 ['-I' + os.path.join(tbb_root, 'include')] if not use_compiler_tbb else []),
69 os.path.join(tbb_root, 'lib', 'intel64', 'gcc4.8'), # for Linux
70 os.path.join(tbb_root, 'lib'), # for MacOS
71 os.path.join(tbb_root, 'lib', 'intel64', 'vc_mt'), # for Windows
/oneTBB/doc/main/reference/
H A Dhelpers_for_expressing_graphs.rst62 join_node<std::tuple<int, int, int>> join(g);
74 make_edge(doubler, std::get<0>(join.input_ports()));
75 make_edge(squarer, std::get<1>(join.input_ports()));
76 make_edge(cuber, std::get<2>(join.input_ports()));
77 make_edge(join, summer);
104 join_node join(follows(handlers));
107 function_node summer(follows(join), serial,
/oneTBB/doc/
H A Dconf.py20 LATEX_DIR = os.path.join(SOURCE_DIR, '_latex')
21 PREAMBLE_FILE = os.path.join(LATEX_DIR, 'preamble.tex')
22 TITLE_PAGE_FILE = os.path.join(LATEX_DIR, 'title_page.tex')
/oneTBB/python/tbb/
H A D__init__.py26 path_to_libs = os.path.join(path_to_env, "Library", "bin")
102 p.join()
107 p.join()
145 p.join()
150 p.join()
298 os.environ[ld_preload] = ':'.join([libtbbmalloc_lib] + list(preload_list))
H A Dpool.py218 def join(self): member in Pool
227 self.join()
231 self.join()
H A Dtest.py201 pool.join()
/oneTBB/doc/main/tbb_userguide/
H A Dparallel_reduce.rst60 void join( const SumFoo& y ) {my_sum+=y.my_sum;}
72 method ``join`` that must be present for ``parallel_reduce`` to work.
96 uses method ``join`` to accumulate the result of the subtask. The graph
97 at the top of the following figure shows the split-join sequence that
105 Graph of the Split-join Sequence
124 Since split/join are not used if workers are unavailable,
173 The join method should do the corresponding merge(s). You can do more
H A DHow_Task_Scheduler_Works.rst8 it was designed to work efficiently for fork-join parallelism with lots of forks.
12 Let's consider the mapping of fork-join parallelism on the task scheduler in more detail.
H A DAdvanced_Example.rst67 void join( const SumFoo& y ) {
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_init_shutdown.cpp88 my_ward.join(); in operator ()()
103 t2b.join(); // t2a is monitored by t2b in Test2()
105 if (t2a.joinable()) t2a.join(); in Test2()
/oneTBB/test/conformance/
H A Dconformance_parallel_reduce.cpp32 int join( int x, int y ) const { in join() function in RotOp
53 void join( const ReduceBody& y ) { in join() function
55 my_value = op.join(my_value, y.my_value); in join()
85 return op.join(v1,v2); in TestDeterministicReductionFor()
H A Dconformance_resumable_tasks.cpp48 t.join();
/oneTBB/test/tbb/
H A Dtest_eh_thread.cpp84 void join() { in join() function in Thread
104 thread.join();
H A Dtest_global_control.cpp224 thr.join();
268 thr2.join();
271 thr1.join();
H A Dtest_flow_graph_whitebox.cpp113 t.join(); in TestBufferingNode()
223 t.join(); in TestContinueNode()
285 t.join(); in TestFunctionNode()
336 t2.join(); in TestFunctionNode()
599 t.join(); in TestMultifunctionNode()
682 t.join(); in TestSequencerNode()
/oneTBB/src/tbb/
H A Drml_thread_monitor.h114 static void join(handle_type handle);
157 void thread_monitor::join(handle_type handle) { in join() function
218 void thread_monitor::join(handle_type handle) { in join() function
H A Dprivate_server.cpp94 static void release_handle(thread_handle my_handle, bool join);
229 void private_worker::release_handle(thread_handle handle, bool join) { in release_handle() argument
230 if (join) in release_handle()
231 thread_monitor::join(handle); in release_handle()
/oneTBB/python/rml/
H A Dipc_server.cpp293 void start_shutdown(bool join);
296 void start_stopping(bool join);
300 static void release_handle(thread_handle my_handle, bool join);
514 void ipc_worker::release_handle(thread_handle handle, bool join) { in release_handle() argument
515 if( join ) in release_handle()
516 ipc_thread_monitor::join( handle ); in release_handle()
521 void ipc_worker::start_shutdown(bool join) { in start_shutdown() argument
536 release_handle( my_handle, join ); in start_shutdown()
540 void ipc_worker::start_stopping(bool join) { in start_stopping() argument
553 release_handle( my_handle, join ); in start_stopping()
/oneTBB/examples/parallel_reduce/pi/
H A Dpi.cpp29 void join(const reduce_body& y) { in join() function
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DLazy_Initialization.rst40 the same ``collaborative_once_flag`` to join other |short_name|
87 // but join parallelism inside functor
/oneTBB/examples/graph/cholesky/
H A DREADME.md10 **join**: A parallel version of Crout-Cholesky factorization that uses the oneTBB flow graph. This …
34 * `algorithm` - name of the used algorithm - can be dpotrf, crout, depend or join.
/oneTBB/examples/parallel_reduce/convex_hull/
H A Dconvex_hull_sample.cpp121 void join(const FindXExtremum &rhs) { in join() function in FindXExtremum
198 void join(const SplitByCP_buf &rhs) { in join() function in SplitByCP_buf
/oneTBB/include/oneapi/tbb/
H A Dparallel_reduce.h40 body.join(rhs); in requires()
76 void join(task_group_context* context) { in join() function
78 left_body.join(*zombie_space.begin()); in join()
242 void join(task_group_context* context) { in join() function
244 left_body.join(right_body); in join()
395 void join( lambda_reduce_body& rhs ) { in join() function
/oneTBB/examples/graph/fgbzip2/
H A Dfgbzip2.cpp152 m_fileReaderThread.join(); in ~AsyncNodeActivity()
153 m_fileWriterThread.join(); in ~AsyncNodeActivity()
/oneTBB/doc/main/intro/
H A Dlimitations.rst46 **Solution:** To work-around the issue, consider using ``task_scheduler_handle`` to join oneTBB wor…

123