Lines Matching refs:threads
42 /* launches a maximum number of threads to process a read */
54 int threads = sysconf(_SC_NPROCESSORS_ONLN);
56 if (threads < WORK_MIN_THREADS) {
57 threads = WORK_MIN_THREADS;
58 } else if (threads > WORK_MAX_THREADS) {
59 threads = WORK_MAX_THREADS;
65 size_t count_per_thread = fec_div_round_up(blocks, threads) * FEC_BLOCKSIZE;
68 if ((size_t)threads > max_threads) {
69 threads = (int)max_threads;
76 debug("%d threads, %zu bytes per thread (total %zu)", threads,
80 process_info info[threads];
83 /* start threads to process queue */
84 for (int i = 0; i < threads; ++i) {
118 /* wait for all threads to complete */
