Lines Matching refs:nthread

731 void DoConcurrentOperations( TableType& table, int n, const char* what, std::size_t nthread ) {  in DoConcurrentOperations()  argument
732 INFO("testing " << what << " with " << nthread << " threads"); in DoConcurrentOperations()
905 void TestInsertFindErase( std::size_t nthread ) { in TestInsertFindErase() argument
922 …tOperations<InsertInitList, test_table_type>( table, n, "insert(std::initializer_list)", nthread ); in TestInsertFindErase()
924 DoConcurrentOperations<Insert, test_table_type>( table, n, "insert", nthread ); in TestInsertFindErase()
929 DoConcurrentOperations<Find, test_table_type>( table, n, "find", nthread ); in TestInsertFindErase()
932 DoConcurrentOperations<FindConst, test_table_type>( table, n, "find(const)", nthread ); in TestInsertFindErase()
936 DoConcurrentOperations<Erase, test_table_type>( table, n, "erase", nthread ); in TestInsertFindErase()
944 if( nthread > 1 ) { in TestInsertFindErase()
948 DoConcurrentOperations<InsertErase,YourTable>(ie_table,n/2,"insert_erase",nthread); in TestInsertFindErase()
952 DoConcurrentOperations<InnerInsert, YourTable>(ie_table,2000,"inner insert",nthread); 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
1025 INFO("testing multiple insertions/deletions of same key with " << nthread << " threads"); in TestConcurrency()
1033 utils::NativeParallelFor( nthread, AddToTable(table,nthread,m) ); in TestConcurrency()
1038 utils::NativeParallelFor( nthread, RemoveFromTable(table,m) ); in TestConcurrency()