274       while (thread_index < queue->num_threads && queue->num_queued == 0)  in util_queue_thread_func()
278       if (thread_index >= queue->num_threads) {  in util_queue_thread_func()
304    if (queue->num_threads == 0) {  in util_queue_thread_func()
351 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads,  in util_queue_adjust_num_threads()  argument
354    num_threads = MIN2(num_threads, queue->max_threads);  in util_queue_adjust_num_threads()
355    num_threads = MAX2(num_threads, 1);  in util_queue_adjust_num_threads()
360    unsigned old_num_threads = queue->num_threads;  in util_queue_adjust_num_threads()
362    if (num_threads == old_num_threads) {  in util_queue_adjust_num_threads()
368    if (num_threads < old_num_threads) {  in util_queue_adjust_num_threads()
369       util_queue_kill_threads(queue, num_threads, true);  in util_queue_adjust_num_threads()
380    queue->num_threads = num_threads;  in util_queue_adjust_num_threads()
381    for (unsigned i = old_num_threads; i < num_threads; i++) {  in util_queue_adjust_num_threads()
383          queue->num_threads = i;  in util_queue_adjust_num_threads()
396                 unsigned num_threads,  in util_queue_init()  argument
432    queue->max_threads = num_threads;  in util_queue_init()
433    queue->num_threads = 1;  in util_queue_init()
453    for (i = 0; i < queue->num_threads; i++) {  in util_queue_init()
460             queue->num_threads = i;  in util_queue_init()
491    if (keep_num_threads >= queue->num_threads) {  in util_queue_kill_threads()
497    unsigned old_num_threads = queue->num_threads;  in util_queue_kill_threads()
501    queue->num_threads = keep_num_threads;  in util_queue_kill_threads()
555    if (queue->num_threads == 0) {  in util_queue_add_job_locked()
573        queue->num_threads < queue->max_threads) {  in util_queue_add_job_locked()
574       util_queue_adjust_num_threads(queue, queue->num_threads + 1, true);  in util_queue_add_job_locked()
697    if (!queue->num_threads) {  in util_queue_finish()
710    fences = malloc(queue->num_threads * sizeof(*fences));  in util_queue_finish()
711    util_barrier_init(&barrier, queue->num_threads);  in util_queue_finish()
713    for (unsigned i = 0; i < queue->num_threads; ++i) {  in util_queue_finish()
721    for (unsigned i = 0; i < queue->num_threads; ++i) {  in util_queue_finish()
733    if (thread_index >= queue->num_threads)  in util_queue_get_thread_time_nano()