Home
last modified time | relevance | path

Searched refs:NativeParallelFor (Results 1 – 25 of 50) sorted by relevance

12

/oneTBB/test/tbb/
H A Dtest_buffer_node.cpp207 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
226 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
230 NativeParallelFor( num_threads, parallel_gets<T>(b, t) ); in test_parallel()
241 NativeParallelFor( num_threads, parallel_put_get<T>(b, t) ); in test_parallel()
252 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
255 NativeParallelFor( num_threads, parallel_gets<T>(b3, t) ); in test_parallel()
271 NativeParallelFor( num_threads, parallel_puts<T>(b) ); in test_parallel()
285 NativeParallelFor( num_threads, parallel_gets<T>(b_copy, t) ); in test_parallel()
H A Dtest_priority_queue_node.cpp175 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
185 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
187 NativeParallelFor( num_threads, parallel_gets<T>(q) ); in test_parallel()
193 NativeParallelFor( num_threads, parallel_put_get<T>(q) ); in test_parallel()
201 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
203 NativeParallelFor( num_threads, parallel_gets<T>(q3) ); in test_parallel()
215 NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
H A Dtest_queue_node.cpp261 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
281 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
285 utils::NativeParallelFor( num_threads, parallel_gets<T>(q, t) ); in test_parallel()
296 utils::NativeParallelFor( num_threads, parallel_put_get<T>(q, t2) ); in test_parallel()
307 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
310 utils::NativeParallelFor( num_threads, parallel_gets<T>(q3, t3) ); in test_parallel()
325 utils::NativeParallelFor( num_threads, parallel_puts<T>(q) ); in test_parallel()
333 utils::NativeParallelFor( num_threads, parallel_gets<T>(q_copy, t) ); in test_parallel()
H A Dtest_tbb_fork.cpp128 utils::NativeParallelFor(4, RunWorkersBody(/*wait_workers=*/false)); in TestBlockNonblock()
154 utils::NativeParallelFor(2, RunInNativeThread(/*blocking=*/false)); in TestTasksInThread()
222 utils::NativeParallelFor(1, RunInNativeThread(/*blocking=*/true)); in TestNestingTSI()
232 utils::NativeParallelFor(1, RunInNativeThread(/*blocking=*/true)); in TestAutoInit()
H A Dtest_global_control.cpp95 utils::NativeParallelFor( rnd.get() % 5 + 1, TestMultpleWaitBody( true ) ); in operator ()()
119 utils::NativeParallelFor( threads, TestMultpleWaitBody() ); in TestMultpleWait()
243 utils::NativeParallelFor(1,
H A Dtest_semaphore.cpp92 utils::NativeParallelFor(n_threads, body); in test_semaphore()
138 utils::NativeParallelFor(n_threads, AddOneBody); in test_binary_semaphore()
270 utils::NativeParallelFor(2, body); in test_producer_consumer()
H A Dtest_task_arena.cpp221 utils::NativeParallelFor( p, &TestConcurrentArenasFunc ); in TestConcurrentArenas()
294 NativeParallelFor( p, MultipleMastersPart1(a, barrier1, barrier2) ); in TestMultipleMasters()
305 NativeParallelFor( p, MultipleMastersPart2(a, barrier) ); in TestMultipleMasters()
313 NativeParallelFor( p+1, MultipleMastersPart3(a, barrier) ); in TestMultipleMasters()
384 NativeParallelFor(3, *this); // test cross-arena calls in test()
485 utils::NativeParallelFor( reserved, test ); in TestArenaConcurrency()
537 utils::NativeParallelFor(n_threads, [&](int) { in TestMandatoryConcurrency()
666 utils::NativeParallelFor( std::max(maxthread,4), TestAttachBody( maxthread ) ); in TestAttach()
1067 utils::NativeParallelFor( 2, TestDelegatedSpawnWaitBody(a, barrier1, barrier2) ); in TestDelegatedSpawnWait()
1466 utils::NativeParallelFor(1, [threads](int idx) { in TestDefaultCreatedWorkersAmount()
[all …]
H A Dtest_tick_count.cpp65 utils::NativeParallelFor(num_of_threads, diff_func);
H A Dtest_mutex.h175 utils::NativeParallelFor(nthread, Work<Counter<M>, TEST_SIZE>(counter)); in test_basic()
185 utils::NativeParallelFor(nthread, Work<Invariant<M, 8>, TEST_SIZE>(invariant)); in test_rw_basic()
H A Dtest_sequencer_node.cpp199 utils::NativeParallelFor( num_threads, parallel_puts<T>(s, num_threads) ); in test_parallel()
202 utils::NativeParallelFor( num_threads, parallel_gets<T>(s, num_threads, t) ); in test_parallel()
222 … utils::NativeParallelFor( num_threads, parallel_put_get<T>(s1, s3, num_threads, counter, t) ); in test_parallel()
236 utils::NativeParallelFor( num_threads, parallel_puts<T>(s_copy, num_threads) ); in test_parallel()
H A Dtest_concurrent_queue_whitebox.cpp81 …utils::NativeParallelFor(static_cast<typename Q::value_type>(utils::MaxThread), FloggerBody<Q>(q, … in test_flogger_help()
H A Dtest_task_group.cpp222 NativeParallelFor( g_MaxConcurrency, SharedGroupBody<task_group_type>(g_MaxConcurrency) ); in TestParallelSpawn()
227 …NativeParallelFor( g_MaxConcurrency, SharedGroupBody<task_group_type>(g_MaxConcurrency, ParallelWa… in TestParallelWait()
234 NativeParallelFor( g_MaxConcurrency, b ); in TestParallelWait()
240 NativeParallelFor( 2, SharedGroupBody<task_group_type>(2, VagabondGroup) ); in TestVagabondGroup()
1010 utils::NativeParallelFor(num_threads, [&](int idx) { in __anoneb262a491102()
H A Dtest_collaborative_call_once.cpp237 utils::NativeParallelFor(N, [&](std::size_t) { in __anon8532fc100602()
311 utils::NativeParallelFor(N, [&](std::size_t) { in __anon8532fc100b02()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_pools.cpp189 utils::NativeParallelFor( p, thr ); in TestSharedPool()
285 utils::NativeParallelFor( p, CrossThreadRun() ); in TestCrossThreadPools()
409 utils::NativeParallelFor( 1, FixedPoolUse(1, pool, MAX_OBJECT, 2) ); in TestFixedBufferPool()
418 utils::NativeParallelFor( 1, FixedPoolUse(1, pool, MAX_OBJECT, 1) ); in TestFixedBufferPool()
423 utils::NativeParallelFor( p, FixedPoolUse(p, pool, MAX_OBJECT/p/2, 10000) ); in TestFixedBufferPool()
427 utils::NativeParallelFor( p, FixedPoolUse(p, pool, MAX_OBJECT/p/2, 1) ); in TestFixedBufferPool()
455 utils::NativeParallelFor( p, FixedPoolNomem(&barrier, pool) ); in TestFixedBufferPool()
460 utils::NativeParallelFor( p, FixedPoolSomeMem(&barrier, pool) ); in TestFixedBufferPool()
471 utils::NativeParallelFor( p, FixedPoolUse(p, pool, MAX_OBJECT/p/2, 1) ); in TestFixedBufferPool()
764 utils::NativeParallelFor( POOLS, check); in TestPoolDetection()
[all …]
H A Dtest_malloc_used_by_lib.cpp77 utils::NativeParallelFor(std::size_t(4), UseDll(utils::GetAddress(lib, "callDll"))); in LoadThreadsUnload()
118 utils::NativeParallelFor(threads, body); in ThreadsLoadUnload()
H A Dtest_malloc_init_shutdown.cpp56 utils::NativeParallelFor(NTasks, [&] (std::size_t thread_idx) { in Test1()
155 utils::NativeParallelFor( 1, TestThread(1) ); in TestKeyDtor()
H A Dtest_malloc_lib_unload.cpp191 utils::NativeParallelFor( 1, Run() );
212 utils::NativeParallelFor( 1, Run() );
H A Dtest_malloc_whitebox.cpp178 utils::NativeParallelFor( p, TestLargeObjCache() ); in TestLargeObjectCache()
344 utils::NativeParallelFor( p, BackRefWork<2*BR_MAX_CNT+2>() ); in TestBackRef()
350 utils::NativeParallelFor( 1, BackRefWork<2*BR_MAX_CNT+2>() ); in TestBackRef()
354 utils::NativeParallelFor( 1, LocalCachesHit() ); in TestBackRef()
356 utils::NativeParallelFor( 2, LocalCachesHit() ); in TestBackRef()
368 utils::NativeParallelFor( MaxThread, TestInvalidBackrefs() ); in TestBackRef()
372 utils::NativeParallelFor( MaxThread, BackRefWork<0>() ); in TestBackRef()
680 utils::NativeParallelFor( p, TestBackendWork(backend) ); in TestBackend()
793 utils::NativeParallelFor( p, RunTestHeapLimit() ); in TestHeapLimit()
1202 utils::NativeParallelFor(num_threads, scen); in LOCCollapsingTester()
[all …]
H A Dtest_malloc_new_handler.cpp79 utils::NativeParallelFor(8, AllocLoopBody());
/oneTBB/test/conformance/
H A Dconformance_global_control.cpp64 utils::NativeParallelFor( threads, StackSizeRun(threads, &barr1, &barr2) ); in TestStackSizeThreadsControl()
123 NativeParallelFor( 2, SetUseRun(barr) ); in TestConcurrentSetUseConcurrency()
189 utils::NativeParallelFor( 2, TestMultipleControlsRun(barrier) ); in TestMultipleControls()
317 utils::NativeParallelFor(1, [&](int) { in __anon3ebcafb90102()
329 utils::NativeParallelFor(1, [&](int) { in __anon3ebcafb90202()
H A Dconformance_mutex.h36 utils::NativeParallelFor(N, GRAIN, [&] (int i) {
187 utils::NativeParallelFor(N, GRAIN, [&](int i) { in TestReaderWriterLock()
213 utils::NativeParallelFor(N, GRAIN, [&] (int) { in TestRWStateMultipleChange()
H A Dconformance_collaborative_call_once.cpp77 utils::NativeParallelFor(num_threads, [&](std::size_t) { in __anon8e61f74e0302()
/oneTBB/test/common/
H A Drwm_upgrade_downgrade.h61 utils::NativeParallelFor(p, Hammer<RWMutex>(rw_mutex)); in test_rwm_upgrade_downgrade()
H A Dgraph_utils.h669 …utils::NativeParallelFor(N, harness_reserving_body<ReservingNodeType, DataType, false>(reserving_n…
675 …utils::NativeParallelFor(N, harness_reserving_body<ReservingNodeType, DataType, true>(reserving_n,…
725 utils::NativeParallelFor(N, native_loop_body<NodeType>(node));
807 utils::NativeParallelFor(N, native_loop_limited_body<NodeType>(node, barrier));
824 utils::NativeParallelFor(N, native_loop_limited_body<NodeType>(node, barrier));
870 utils::NativeParallelFor( threshold * 2, [&](int i){
H A Dconcurrent_priority_queue_common.h322 utils::NativeParallelFor(n, filler); in test_parallel_push_pop()
328 utils::NativeParallelFor(n, emptier); in test_parallel_push_pop()
336 utils::NativeParallelFor(n, FloggerBody<T, C>{&q}); in test_flogger()

12