Lines Matching full:threads
39 let threads = num_cpus::get(); in par_inout() localVariable
40 let steps = TOTAL_STEPS / threads; in par_inout()
46 for _ in 0..threads { in par_inout()
59 for _ in 0..threads { in par_inout()
62 for _ in 0..threads { in par_inout()
102 let threads = num_cpus::get() - 1; in spmc() localVariable
103 let steps = TOTAL_STEPS / threads; in spmc()
109 for _ in 0..threads { in spmc()
121 for _ in 0..threads { in spmc()
124 for i in 0..steps * threads { in spmc()
127 for _ in 0..threads { in spmc()
138 let threads = num_cpus::get() - 1; in mpsc() localVariable
139 let steps = TOTAL_STEPS / threads; in mpsc()
145 for _ in 0..threads { in mpsc()
157 for _ in 0..threads { in mpsc()
160 for _ in 0..steps * threads { in mpsc()
163 for _ in 0..threads { in mpsc()
174 let threads = num_cpus::get(); in mpmc() localVariable
175 let steps = TOTAL_STEPS / threads; in mpmc()
181 for _ in 0..threads / 2 { in mpmc()
191 for _ in 0..threads / 2 { in mpmc()
203 for _ in 0..threads { in mpmc()
206 for _ in 0..threads { in mpmc()
250 let threads = num_cpus::get() - 1; in spmc() localVariable
251 let steps = TOTAL_STEPS / threads; in spmc()
252 let (s, r) = bounded::<i32>(steps * threads); in spmc()
257 for _ in 0..threads { in spmc()
269 for _ in 0..threads { in spmc()
272 for i in 0..steps * threads { in spmc()
275 for _ in 0..threads { in spmc()
286 let threads = num_cpus::get() - 1; in mpsc() localVariable
287 let steps = TOTAL_STEPS / threads; in mpsc()
288 let (s, r) = bounded::<i32>(steps * threads); in mpsc()
293 for _ in 0..threads { in mpsc()
305 for _ in 0..threads { in mpsc()
308 for _ in 0..steps * threads { in mpsc()
311 for _ in 0..threads { in mpsc()
322 let threads = num_cpus::get(); in par_inout() localVariable
323 let steps = TOTAL_STEPS / threads; in par_inout()
324 let (s, r) = bounded::<i32>(threads); in par_inout()
329 for _ in 0..threads { in par_inout()
342 for _ in 0..threads { in par_inout()
345 for _ in 0..threads { in par_inout()
356 let threads = num_cpus::get(); in mpmc() localVariable
357 assert_eq!(threads % 2, 0); in mpmc()
358 let steps = TOTAL_STEPS / threads; in mpmc()
359 let (s, r) = bounded::<i32>(steps * threads); in mpmc()
364 for _ in 0..threads / 2 { in mpmc()
374 for _ in 0..threads / 2 { in mpmc()
386 for _ in 0..threads { in mpmc()
389 for _ in 0..threads { in mpmc()
447 let threads = num_cpus::get() - 1; in spmc() localVariable
448 let steps = TOTAL_STEPS / threads; in spmc()
454 for _ in 0..threads { in spmc()
466 for _ in 0..threads { in spmc()
469 for i in 0..steps * threads { in spmc()
472 for _ in 0..threads { in spmc()
483 let threads = num_cpus::get() - 1; in mpsc() localVariable
484 let steps = TOTAL_STEPS / threads; in mpsc()
490 for _ in 0..threads { in mpsc()
502 for _ in 0..threads { in mpsc()
505 for _ in 0..steps * threads { in mpsc()
508 for _ in 0..threads { in mpsc()
519 let threads = num_cpus::get(); in mpmc() localVariable
520 let steps = TOTAL_STEPS / threads; in mpmc()
526 for _ in 0..threads / 2 { in mpmc()
536 for _ in 0..threads / 2 { in mpmc()
548 for _ in 0..threads { in mpmc()
551 for _ in 0..threads { in mpmc()
600 let threads = num_cpus::get() - 1; in spmc() localVariable
601 let steps = TOTAL_STEPS / threads; in spmc()
607 for _ in 0..threads { in spmc()
619 for _ in 0..threads { in spmc()
622 for i in 0..steps * threads { in spmc()
625 for _ in 0..threads { in spmc()
636 let threads = num_cpus::get() - 1; in mpsc() localVariable
637 let steps = TOTAL_STEPS / threads; in mpsc()
643 for _ in 0..threads { in mpsc()
655 for _ in 0..threads { in mpsc()
658 for _ in 0..steps * threads { in mpsc()
661 for _ in 0..threads { in mpsc()
672 let threads = num_cpus::get(); in mpmc() localVariable
673 let steps = TOTAL_STEPS / threads; in mpmc()
679 for _ in 0..threads / 2 { in mpmc()
689 for _ in 0..threads / 2 { in mpmc()
701 for _ in 0..threads { in mpmc()
704 for _ in 0..threads { in mpmc()