Lines Matching refs:num_threads
619 static OPJ_BOOL opj_thread_pool_setup(opj_thread_pool_t* tp, int num_threads);
625 opj_thread_pool_t* opj_thread_pool_create(int num_threads)
635 if (num_threads <= 0) {
649 if (!opj_thread_pool_setup(tp, num_threads)) {
684 static OPJ_BOOL opj_thread_pool_setup(opj_thread_pool_t* tp, int num_threads)
689 assert(num_threads > 0);
696 tp->worker_threads = (opj_worker_thread_t*) opj_calloc((size_t)num_threads,
701 tp->worker_threads_count = num_threads;
703 for (i = 0; i < num_threads; i++) {
735 while (tp->waiting_worker_thread_count < num_threads) {
