Searched refs:N_THREADS (Results 1 – 9 of 9) sorted by relevance
28 private val N_THREADS = 4 constant in kotlinx.coroutines.scheduling.CoroutineSchedulerCloseStressTest56 closeableDispatcher = ExperimentalCoroutineDispatcher(N_THREADS) in <lambda>()59 … Mode.CPU_LIMITED -> closeableDispatcher.limited(N_THREADS) as ExecutorCoroutineDispatcher in <lambda>()60 Mode.BLOCKING -> closeableDispatcher.blocking(N_THREADS) as ExecutorCoroutineDispatcher in <lambda>()
5 const N_THREADS: usize = 32; constant13 (0..N_THREADS).map(|i| std::thread::spawn(move || thread_main(i))).collect::<Vec<_>>(); in main()26 assert!(value < N_THREADS) in thread_main()
4 const N_THREADS: usize = 32; constant16 let threads = (0..N_THREADS) in main()26 let threads = (0..N_THREADS) in main()
12 const N_THREADS: usize = 32; constant22 (0..N_THREADS).map(|i| std::thread::spawn(move || thread_main(i))).collect::<Vec<_>>(); in main()
8 const N_THREADS: usize = 16; constant17 (0..N_THREADS).map(|i| std::thread::spawn(move || thread_main(i))).collect::<Vec<_>>(); in main()
45 const N_THREADS: usize = 32; in many_threads_calling_get() constant63 let barrier = Arc::new(Barrier::new(N_THREADS)); in many_threads_calling_get()65 for _ in 0..N_THREADS { in many_threads_calling_get()
68 const N_THREADS: usize = 32; in many_threads_calling_get() constant86 let barrier = Arc::new(Barrier::new(N_THREADS)); in many_threads_calling_get()88 for _ in 0..N_THREADS { in many_threads_calling_get()
314 N_THREADS = 2359 for i in range(N_THREADS):
370 N_THREADS = 2415 for i in range(N_THREADS):