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()
135 if (nrequeue > nthreads) in bench_futex_requeue()
136 nrequeue = nthreads; in bench_futex_requeue()
139 "%d at a time.\n\n", getpid(), nthreads, in bench_futex_requeue()
167 while (nrequeued < nthreads) { in bench_futex_requeue()
184 j + 1, nrequeued, nthreads, runtime.tv_usec/1e3); in bench_futex_requeue()
189 if (nthreads != nrequeued) in bench_futex_requeue()
190 warnx("couldn't wakeup all tasks (%d/%d)", nrequeued, nthreads); in bench_futex_requeue()
192 for (i = 0; i < nthreads; i++) { in bench_futex_requeue()