Lines Matching refs:nthreads
37 static unsigned int ncpus, threads_starting, nthreads = 0; variable
41 OPT_UINTEGER('t', "threads", &nthreads, "Specify amount of threads"),
61 nthreads, in print_summary()
85 threads_starting = nthreads; in block_threads()
88 for (i = 0; i < nthreads; i++) { in block_threads()
125 if (!nthreads) in bench_futex_requeue()
126 nthreads = ncpus; in bench_futex_requeue()
128 worker = calloc(nthreads, sizeof(*worker)); in bench_futex_requeue()
136 "%d at a time.\n\n", getpid(), nthreads, in bench_futex_requeue()
164 for (nrequeued = 0; nrequeued < nthreads; nrequeued += nrequeue) { in bench_futex_requeue()
175 if (nrequeued > nthreads) in bench_futex_requeue()
176 nrequeued = nthreads; in bench_futex_requeue()
183 j + 1, nrequeued, nthreads, runtime.tv_usec/1e3); in bench_futex_requeue()
187 nrequeued = futex_wake(&futex2, nthreads, futex_flag); in bench_futex_requeue()
188 if (nthreads != nrequeued) in bench_futex_requeue()
189 warnx("couldn't wakeup all tasks (%d/%d)", nrequeued, nthreads); in bench_futex_requeue()
191 for (i = 0; i < nthreads; i++) { in bench_futex_requeue()