Lines Matching defs:nwaking_threads
52 static unsigned int nblocked_threads = 0, nwaking_threads = 0;
62 OPT_UINTEGER('w', "nwakers", &nwaking_threads, "Specify amount of waking threads"),
100 pthread_barrier_init(&barrier, NULL, nwaking_threads + 1);
103 for (i = 0; i < nwaking_threads; i++) {
116 for (i = 0; i < nwaking_threads; i++)
171 for (i = 0; i < nwaking_threads; i++) {
207 for (i = 0; i < nwaking_threads; i++) {
250 if (nwaking_threads > nblocked_threads || !nwaking_threads)
251 nwaking_threads = nblocked_threads;
253 if (nblocked_threads % nwaking_threads)
259 nwakes = nblocked_threads/nwaking_threads;
271 &futex, nwaking_threads, nwakes);
282 waking_worker = calloc(nwaking_threads, sizeof(*waking_worker));