Searched refs:kThreads (Results 1 – 14 of 14) sorted by relevance
28 const int kThreads = 16; // code below expects that this is a multiple of 4 in test_parallelism() local29 NonBlockingThreadPool tp(kThreads); in test_parallelism()30 VERIFY_IS_EQUAL(tp.NumThreads(), kThreads); in test_parallelism()37 for (int i = 0; i < kThreads; ++i) { in test_parallelism()41 VERIFY_LE(thread_id, kThreads - 1); in test_parallelism()48 while (running != kThreads) { in test_parallelism()54 for (int i = 0; i < kThreads; ++i) { in test_parallelism()64 if (i < kThreads / 2) { in test_parallelism()65 } else if (i < 3 * kThreads / 4) { in test_parallelism()83 while (running != kThreads) { in test_parallelism()[all …]
81 const int kThreads = std::thread::hardware_concurrency(); in test_stress_eventcount() local85 MaxSizeVector<EventCount::Waiter> waiters(kThreads); in test_stress_eventcount()86 waiters.resize(kThreads); in test_stress_eventcount()91 for (int i = 0; i < kThreads; i++) { in test_stress_eventcount()107 for (int i = 0; i < kThreads; i++) { in test_stress_eventcount()132 for (int i = 0; i < kThreads; i++) { in test_stress_eventcount()
65 const int kThreads = 8; variable99 pthread_t threads[kThreads]; in TEST()100 for (int i = 0; i < kThreads; i++) in TEST()102 for (int i = 0; i < kThreads; i++) in TEST()109 pthread_t threads[kThreads]; in TEST()110 for (int i = 0; i < kThreads; i++) in TEST()112 for (int i = 0; i < kThreads; i++) in TEST()119 pthread_t threads[kThreads]; in TEST()120 for (int i = 0; i < kThreads; i++) in TEST()122 for (int i = 0; i < kThreads; i++) in TEST()
215 const uptr kThreads = 4; variable221 u64 clock[kThreads];230 for (uptr i = 0; i < kThreads; i++) in Reset()250 u64 clock[kThreads];257 for (uptr i = 0; i < kThreads; i++) in SimpleThreadClock()268 for (uptr i = 0; i < kThreads; i++) in acquire()275 for (uptr i = 0; i < kThreads; i++) in release()287 for (uptr i = 0; i < kThreads; i++) in ReleaseStore()308 SimpleThreadClock *thr0[kThreads]; in ClockFuzzer()309 ThreadClock *thr1[kThreads]; in ClockFuzzer()[all …]
70 const int kThreads = 8; variable107 pthread_t threads[kThreads]; in TEST()108 for (int i = 0; i < kThreads; i++) in TEST()110 for (int i = 0; i < kThreads; i++) in TEST()118 pthread_t threads[kThreads]; in TEST()119 for (int i = 0; i < kThreads; i++) in TEST()121 for (int i = 0; i < kThreads; i++) in TEST()129 pthread_t threads[kThreads]; in TEST()130 for (int i = 0; i < kThreads; i++) in TEST()132 for (int i = 0; i < kThreads; i++) in TEST()
4 const int kThreads = 16; variable16 pthread_t th[kThreads]; in main()17 for (int i = 0; i < kThreads; i++) in main()19 for (int i = 0; i < kThreads; i++) in main()
13 const int kThreads = 10; in main() local14 barrier_init(&barrier, kThreads + 1); in main()15 pthread_t t[kThreads]; in main()20 for (int i = 0; i < kThreads; i++) in main()
24 const int kThreads = 10; in main() local25 pthread_t th[kThreads]; in main()26 for (int i = 0; i < kThreads; i++) in main()47 for (int i = 0; i < kThreads; i++) in main()
13 const int kThreads = 4; variable176 pthread_t t[kThreads]; in main()177 for (int i = 0; i < kThreads; i++) in main()179 for (int i = 0; i < kThreads; i++) in main()
64 const int kThreads = 10; in test() local65 pthread_t t[kThreads]; in test()66 for (int i = 0; i < kThreads; ++i) in test()
81 const int kThreads = 4; in local_thread() local82 pthread_t th[kThreads]; in local_thread()83 for (int i = 0; i < kThreads; i++) in local_thread()86 for (int i = 0; i < kThreads; i++) in local_thread()
48 const int kThreads = 70000; in TEST() local51 for (int i = 0; i < kThreads; i++) { in TEST()
34 const int kThreads = 0; variable99 cfg.threads = std::get<kThreads>(input); in TEST_P()
32 const int kThreads = 0; variable112 cfg.threads = ::testing::get<kThreads>(input); in TEST_P()