Home
last modified time | relevance | path

Searched refs:nthreads (Results 1 – 16 of 16) sorted by relevance

/oneTBB/examples/parallel_for/polygon_overlay/
H A Dpolyover.cpp157 for (int nthreads = gThreadsLow; nthreads <= gThreadsHigh; nthreads++) { in NaiveParallelOverlay() local
179 std::cout << nthreads; in NaiveParallelOverlay()
404 int nthreads; in SplitParallelOverlay() local
427 for (nthreads = gThreadsLow; nthreads <= gThreadsHigh; nthreads++) { in SplitParallelOverlay()
447 std::cout << nthreads; in SplitParallelOverlay()
533 int nthreads; in SplitParallelOverlayCV() local
554 for (nthreads = gThreadsLow; nthreads <= gThreadsHigh; nthreads++) { in SplitParallelOverlayCV()
574 std::cout << nthreads; in SplitParallelOverlayCV()
668 int nthreads; in SplitParallelOverlayETS() local
689 for (nthreads = gThreadsLow; nthreads <= gThreadsHigh; nthreads++) { in SplitParallelOverlayETS()
[all …]
/oneTBB/examples/parallel_for/tachyon/src/
H A Dtrace.threads.cpp70 static int nthreads; variable
174 sched_nexty += ((stopy - starty + 1) / nthreads); in schedule_thread_work()
255 nthreads = get_num_cpus(); in thread_trace()
258 nthreads = n; in thread_trace()
262 pthread_t *threads = (pthread_t *)alloca(nthreads * sizeof(pthread_t)); in thread_trace()
267 for (int i = 0; i < nthreads; i++) { in thread_trace()
271 for (int i = 0; i < nthreads; i++) { in thread_trace()
H A Dtrace.threads2d.cpp70 static int nthreads; variable
307 nthreads = get_num_cpus(); in thread_trace()
310 nthreads = n; in thread_trace()
314 pthread_t *threads = (pthread_t *)alloca(nthreads * sizeof(pthread_t)); in thread_trace()
319 for (int i = 0; i < nthreads; i++) { in thread_trace()
323 for (int i = 0; i < nthreads; i++) { in thread_trace()
H A Dtrace.tbb1d.cpp185 int n, nthreads = utility::get_default_num_threads(); in thread_trace() local
188 nthreads = n; in thread_trace()
189 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, nthreads); in thread_trace()
H A Dtrace.tbb.cpp253 int n, nthreads = utility::get_default_num_threads(); in thread_trace() local
256 nthreads = n; in thread_trace()
257 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, nthreads); in thread_trace()
/oneTBB/examples/parallel_reduce/convex_hull/
H A Dconvex_hull_sample.cpp271 int nthreads; in main() local
280 for (nthreads = threads.first; nthreads <= threads.last; nthreads = threads.step(nthreads)) { in main()
282 nthreads); in main()
289 std::cout << "Init time on " << nthreads in main()
298 std::cout << "Time on " << nthreads << " threads: " << util::time_diff(tm_start, tm_end) in main()
H A Dconvex_hull_bench.cpp589 int nthreads; in main() local
600 for (nthreads = threads.first; nthreads <= threads.last; nthreads = threads.step(nthreads)) { in main()
605 nthreads); in main()
609 std::cout << "Parallel init time on " << nthreads in main()
616 std::cout << "Time on " << nthreads << " threads: " << util::time_diff(tm_start, tm_end) in main()
628 for (nthreads = threads.first; nthreads <= threads.last; nthreads = threads.step(nthreads)) { in main()
633 nthreads); in main()
638 std::cout << "Init time on " << nthreads in main()
645 std::cout << "Time on " << nthreads << " threads: " << util::time_diff(tm_start, tm_end) in main()
H A Dconvex_hull.hpp173 void WriteResults(int nthreads, double initTime, double calcTime) { in WriteResults() argument
182 << " Number of threads:" << nthreads << " Initialization time:" << std::setw(10) in WriteResults()
/oneTBB/test/common/
H A Dspin_barrier.h114 SpinBarrier( size_type nthreads = 0, bool throwaway = false ) {
115 initialize(nthreads, throwaway);
118 void initialize( size_type nthreads, bool throwaway = false ) {
119 myNumThreads = nthreads;
H A Dcpu_usertime.h70 inline void TestCPUUserTime( std::size_t nthreads, std::size_t nactive = 1 ) {
74 std::size_t nworkers = nthreads-nactive;
/oneTBB/test/tbb/
H A Dtest_overwrite_node.cpp126 const int nthreads = 30; in parallel_read_write_tests() local
128 const int nthreads = N; in parallel_read_write_tests() local
130 utils::NativeParallelFor( nthreads, native_body<R>( ow_vec[node_idx] ) ); in parallel_read_write_tests()
134 CHECK_MESSAGE( int(c) == nthreads, "" ); in parallel_read_write_tests()
142 CHECK_MESSAGE( int(c) == nthreads, "" ); in parallel_read_write_tests()
H A Dtest_async_node.cpp533 static int run(int nthreads, int async_expected_items = UNKNOWN_NUMBER_OF_ITEMS) { in run()
535 const int overall_message_count = nthreads * NUMBER_OF_MSGS; in run()
536 utils::SpinBarrier spin_barrier(nthreads); in run()
589 const int nthreads = 4; in test_for_spin_avoidance() local
590 tbb::global_control gc(tbb::global_control::max_allowed_parallelism, nthreads); in test_for_spin_avoidance()
591 tbb::task_arena a(nthreads); in test_for_spin_avoidance()
593 spin_test<int, int>::run(nthreads); in test_for_spin_avoidance()
654 const int nthreads = tbb::this_task_arena::max_concurrency(); in run() local
655 utils::SpinBarrier spin_barrier( nthreads ); in run()
659 tbb::parallel_for( 0, nthreads, body_graph_with_async( spin_barrier, my_async_activity ) ); in run()
H A Dtest_write_once_node.cpp150 const int nthreads = 30; in parallel_read_write_tests() local
152 const int nthreads = N; in parallel_read_write_tests() local
154 utils::NativeParallelFor( nthreads, native_body<R>( wo_vec[node_idx] ) ); in parallel_read_write_tests()
/oneTBB/test/conformance/
H A Dconformance_concurrent_queue.cpp987 for (std::size_t nthreads = MinThread; nthreads <= MaxThread; ++nthreads) { in TestAbort() local
995 SimplePushBody my_push_body1(&iq1, nthreads); in TestAbort()
1000 if (nthreads < (MaxThread + MinThread) / 2) { in TestAbort()
1014 SimplePushBody my_push_body2(&iq2, nthreads); in TestAbort()
1017 if (nthreads>= 2) in TestAbort()
1032 SimplePopBody my_pop_body(&iq3, nthreads, 2); in TestAbort()
1035 if (nthreads>= 2) in TestAbort()
1044 std::size_t cap = nthreads / 2; in TestAbort()
1052 SimplePushBody my_push_body2(&iq4, nthreads); in TestAbort()
1055 if (nthreads>= cap) in TestAbort()
[all …]
/oneTBB/examples/concurrent_hash_map/count_strings/
H A Dcount_strings.cpp96 static void CountOccurrences(int nthreads) { in CountOccurrences() argument
106 if (verbose && nthreads) in CountOccurrences()
/oneTBB/examples/parallel_pipeline/square/
H A Dsquare.cpp190 int run_pipeline(int nthreads) { in run_pipeline() argument
207 nthreads * 4, in run_pipeline()