288       while (thread_index < queue->num_threads && queue->num_queued == 0)  in util_queue_thread_func()
292       if (thread_index >= queue->num_threads) {  in util_queue_thread_func()
317    if (queue->num_threads == 0) {  in util_queue_thread_func()
365 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads)  in util_queue_adjust_num_threads()  argument
367    num_threads = MIN2(num_threads, queue->max_threads);  in util_queue_adjust_num_threads()
368    num_threads = MAX2(num_threads, 1);  in util_queue_adjust_num_threads()
371    unsigned old_num_threads = queue->num_threads;  in util_queue_adjust_num_threads()
373    if (num_threads == old_num_threads) {  in util_queue_adjust_num_threads()
378    if (num_threads < old_num_threads) {  in util_queue_adjust_num_threads()
379       util_queue_kill_threads(queue, num_threads, true);  in util_queue_adjust_num_threads()
389    queue->num_threads = num_threads;  in util_queue_adjust_num_threads()
390    for (unsigned i = old_num_threads; i < num_threads; i++) {  in util_queue_adjust_num_threads()
401                 unsigned num_threads,  in util_queue_init()  argument
435    queue->max_threads = num_threads;  in util_queue_init()
436    queue->num_threads = num_threads;  in util_queue_init()
451    queue->threads = (thrd_t*) calloc(num_threads, sizeof(thrd_t));  in util_queue_init()
456    for (i = 0; i < num_threads; i++) {  in util_queue_init()
463             queue->num_threads = i;  in util_queue_init()
496    if (keep_num_threads >= queue->num_threads) {  in util_queue_kill_threads()
502    unsigned old_num_threads = queue->num_threads;  in util_queue_kill_threads()
506    queue->num_threads = keep_num_threads;  in util_queue_kill_threads()
542    if (queue->num_threads == 0) {  in util_queue_add_job()
667    if (!queue->num_threads) {  in util_queue_finish()
672    fences = malloc(queue->num_threads * sizeof(*fences));  in util_queue_finish()
673    util_barrier_init(&barrier, queue->num_threads);  in util_queue_finish()
675    for (unsigned i = 0; i < queue->num_threads; ++i) {  in util_queue_finish()
681    for (unsigned i = 0; i < queue->num_threads; ++i) {  in util_queue_finish()
696    if (thread_index >= queue->num_threads)  in util_queue_get_thread_time_nano()