| /oneTBB/examples/parallel_for/game_of_life/ |
| H A D | Evolution.cpp | 53 void SequentialEvolution::Run(double execution_time, int nthread) { in Run() argument
95 void ParallelEvolution::Run(double execution_time, int nthread) { in Run() argument
96 if (nthread == utility::get_default_num_threads()) in Run()
99 printf("Starting game (Parallel evolution for %d thread(s))\n", nthread); in Run()
105 oneapi::tbb::global_control::max_allowed_parallelism, nthread); in Run()
|
| H A D | Evolution.hpp | 62 virtual void Run(double execution_time, int nthread) = 0;
110 virtual void Run(double execution_time, int nthread);
130 virtual void Run(double execution_time, int nthread);
|
| /oneTBB/test/tbb/ |
| H A D | test_concurrent_queue.cpp | 33 const std::size_t nthread; member
34 TestQueueElements( CQ& q, std::size_t n ) : queue(q), nthread(n) {} in TestQueueElements()
38 CHECK(T(k) < T(nthread)); in operator ()()
44 CHECK(item <= T(nthread)); in operator ()()
52 void TestPrimitiveTypes(std::size_t nthread, T exemplar) { in TestPrimitiveTypes() argument
57 utils::NativeParallelFor(nthread, TestQueueElements<CQ, T>(queue, nthread)); in TestPrimitiveTypes()
|
| H A D | test_mutex.h | 171 void test_basic( std::size_t nthread ) { in test_basic() argument
175 utils::NativeParallelFor(nthread, Work<Counter<M>, TEST_SIZE>(counter)); in test_basic()
181 void test_rw_basic( std::size_t nthread ) { in test_rw_basic() argument
185 utils::NativeParallelFor(nthread, Work<Invariant<M, 8>, TEST_SIZE>(invariant)); in test_rw_basic()
|
| H A D | test_parallel_reduce.cpp | 454 template <typename Partitioner_> friend void TestSplitting( std::size_t nthread );
468 template <typename Partitioner_> friend void TestSplitting( std::size_t nthread );
526 void TestSplitting( std::size_t nthread ) { in TestSplitting() argument
535 if (nthread == 1) REQUIRE_MESSAGE(ForkCount==0, "Body was split during 1 thread execution"); in TestSplitting()
|
| H A D | test_concurrent_vector.cpp | 157 double TimeFindPrimes( std::size_t nthread ) { in TimeFindPrimes() argument
162 std::size_t block_size = count / nthread; in TimeFindPrimes()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_combinable.cpp | 429 const int nthread; member
431 …Body( int nthread_, int niters_ ) : nthread(nthread_), nIters(niters_) { sBarrier.initialize(nthre… in Body()
448 void TestLocalAllocations( int nthread ) { in TestLocalAllocations() argument
449 REQUIRE_MESSAGE(nthread > 0, "nthread must be positive"); in TestLocalAllocations()
451 Body myBody(nthread, NITERATIONS); in TestLocalAllocations()
455 NativeParallelFor( nthread, myBody ); in TestLocalAllocations()
462 REQUIRE_MESSAGE(nthread == mySlots, "Incorrect number of slots"); in TestLocalAllocations()
463 REQUIRE_MESSAGE(mySum == (nthread - 1) * nthread / 2, "Incorrect values in result"); in TestLocalAllocations()
|
| H A D | conformance_concurrent_queue.cpp | 593 const std::size_t nthread; member
620 void TestNegativeQueue( std::size_t nthread ) { in TestNegativeQueue() argument
622 utils::NativeParallelFor( nthread, TestNegativeQueueBody<T>(queue,nthread)); in TestNegativeQueue()
641 const std::size_t nthread; member
647 CHECK(thread_id < nthread); in operator ()()
681 CHECK(nthread> 0); in TestPushPop()
695 Body<CQ,T> body(nthread); in TestPushPop()
701 f.set_thread_id(nthread); in TestPushPop()
708 utils::NativeParallelFor( nthread, body); in TestPushPop()
731 if (nthread> 1 && prefill == 0) { in TestPushPop()
[all …]
|
| H A D | conformance_concurrent_hash_map.cpp | 732 INFO("testing " << what << " with " << nthread << " threads"); in DoConcurrentOperations()
905 void TestInsertFindErase( std::size_t nthread ) { in TestInsertFindErase() argument
929 DoConcurrentOperations<Find, test_table_type>( table, n, "find", nthread ); in TestInsertFindErase()
936 DoConcurrentOperations<Erase, test_table_type>( table, n, "erase", nthread ); in TestInsertFindErase()
944 if( nthread > 1 ) { in TestInsertFindErase()
953 utils::SpinBarrier barrier(nthread); in TestInsertFindErase()
955 utils::NativeParallelFor( nthread, FakeExclusive(barrier, ie_table)); in TestInsertFindErase()
970 …AddToTable( test_table_type& table, std::size_t nthread, int m ) : my_table(table), my_nthread(nth… in AddToTable() argument
1024 void TestConcurrency( std::size_t nthread ) { in TestConcurrency() argument
1033 utils::NativeParallelFor( nthread, AddToTable(table,nthread,m) ); in TestConcurrency()
[all …]
|
| H A D | conformance_concurrent_vector.cpp | 782 void TestParallelFor( std::size_t nthread ) { in TestParallelFor() argument
787 INFO("Calling parallel_for with " << nthread << " threads"); in TestParallelFor()
|