Lines Matching refs:num_threads

309       while (thread_index < queue->num_threads && queue->num_queued == 0)
312 /* only kill threads that are above "num_threads" */
313 if (thread_index >= queue->num_threads) {
339 if (queue->num_threads == 0) {
388 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads)
390 num_threads = MIN2(num_threads, queue->max_threads);
391 num_threads = MAX2(num_threads, 1);
394 unsigned old_num_threads = queue->num_threads;
396 if (num_threads == old_num_threads) {
401 if (num_threads < old_num_threads) {
402 util_queue_kill_threads(queue, num_threads, true);
409 * We need to update num_threads first, because threads terminate
410 * when thread_index < num_threads.
412 queue->num_threads = num_threads;
413 for (unsigned i = old_num_threads; i < num_threads; i++) {
424 unsigned num_threads,
459 queue->max_threads = num_threads;
460 queue->num_threads = (flags & UTIL_QUEUE_INIT_SCALE_THREADS) ? 1 : num_threads;
481 for (i = 0; i < queue->num_threads; i++) {
488 queue->num_threads = i;
521 if (keep_num_threads >= queue->num_threads) {
527 unsigned old_num_threads = queue->num_threads;
528 /* Setting num_threads is what causes the threads to terminate.
531 queue->num_threads = keep_num_threads;
577 if (queue->num_threads == 0) {
594 queue->num_threads < queue->max_threads) {
595 util_queue_adjust_num_threads(queue, queue->num_threads + 1);
704 if (!queue->num_threads) {
709 fences = malloc(queue->num_threads * sizeof(*fences));
710 util_barrier_init(&barrier, queue->num_threads);
712 for (unsigned i = 0; i < queue->num_threads; ++i) {
718 for (unsigned i = 0; i < queue->num_threads; ++i) {
733 if (thread_index >= queue->num_threads)