Lines Matching refs:threads
92 thread_t* threads[5]; in mutex_test() local
94 for (uint i = 0; i < fbl::count_of(threads); i++) { in mutex_test()
95 threads[i] = thread_create("mutex tester", &mutex_thread, &m, in mutex_test()
97 thread_resume(threads[i]); in mutex_test()
100 for (uint i = 0; i < fbl::count_of(threads); i++) { in mutex_test()
101 thread_join(threads[i], NULL, ZX_TIME_INFINITE); in mutex_test()
221 thread_t* threads[5]; in event_test() local
232 threads[0] = thread_create("event signaler", &event_signaler, NULL, DEFAULT_PRIORITY); in event_test()
233 threads[1] = thread_create("event waiter 0", &event_waiter, (void*)2, DEFAULT_PRIORITY); in event_test()
234 threads[2] = thread_create("event waiter 1", &event_waiter, (void*)2, DEFAULT_PRIORITY); in event_test()
235 threads[3] = thread_create("event waiter 2", &event_waiter, (void*)2, DEFAULT_PRIORITY); in event_test()
236 threads[4] = thread_create("event waiter 3", &event_waiter, (void*)2, DEFAULT_PRIORITY); in event_test()
238 for (uint i = 0; i < fbl::count_of(threads); i++) in event_test()
239 thread_resume(threads[i]); in event_test()
241 for (uint i = 0; i < fbl::count_of(threads); i++) in event_test()
242 thread_join(threads[i], NULL, ZX_TIME_INFINITE); in event_test()
251 threads[0] = thread_create("event signaler", &event_signaler, NULL, DEFAULT_PRIORITY); in event_test()
252 threads[1] = thread_create("event waiter 0", &event_waiter, (void*)99, DEFAULT_PRIORITY); in event_test()
253 threads[2] = thread_create("event waiter 1", &event_waiter, (void*)99, DEFAULT_PRIORITY); in event_test()
254 threads[3] = thread_create("event waiter 2", &event_waiter, (void*)99, DEFAULT_PRIORITY); in event_test()
255 threads[4] = thread_create("event waiter 3", &event_waiter, (void*)99, DEFAULT_PRIORITY); in event_test()
257 for (uint i = 0; i < fbl::count_of(threads); i++) in event_test()
258 thread_resume(threads[i]); in event_test()
262 for (uint i = 0; i < fbl::count_of(threads); i++) { in event_test()
263 thread_kill(threads[i]); in event_test()
264 thread_join(threads[i], NULL, ZX_TIME_INFINITE); in event_test()
369 thread_t* threads[8]; in atomic_test() local
370 threads[0] = thread_create("atomic tester 1", &atomic_tester, (void*)1, LOW_PRIORITY); in atomic_test()
371 threads[1] = thread_create("atomic tester 1", &atomic_tester, (void*)1, LOW_PRIORITY); in atomic_test()
372 threads[2] = thread_create("atomic tester 1", &atomic_tester, (void*)1, LOW_PRIORITY); in atomic_test()
373 threads[3] = thread_create("atomic tester 1", &atomic_tester, (void*)1, LOW_PRIORITY); in atomic_test()
374 threads[4] = thread_create("atomic tester 2", &atomic_tester, (void*)-1, LOW_PRIORITY); in atomic_test()
375 threads[5] = thread_create("atomic tester 2", &atomic_tester, (void*)-1, LOW_PRIORITY); in atomic_test()
376 threads[6] = thread_create("atomic tester 2", &atomic_tester, (void*)-1, LOW_PRIORITY); in atomic_test()
377 threads[7] = thread_create("atomic tester 2", &atomic_tester, (void*)-1, LOW_PRIORITY); in atomic_test()
380 for (uint i = 0; i < fbl::count_of(threads); i++) in atomic_test()
381 thread_resume(threads[i]); in atomic_test()
384 for (uint i = 0; i < fbl::count_of(threads); i++) { in atomic_test()
385 thread_join(threads[i], NULL, ZX_TIME_INFINITE); in atomic_test()
687 thread_t* threads[16] = {};
707 int which = rand() % static_cast<int>(fbl::count_of(state->threads)); in affinity_test_thread()
711 thread_set_cpu_affinity(state->threads[which], (cpu_mask_t)rand()); in affinity_test_thread()
755 for (auto& t : state.threads) { in affinity_test()
760 for (auto& t : state.threads) { in affinity_test()
773 for (auto& t : state.threads) { in affinity_test()