Home | History | Annotate | Download | only in parallel

Lines Matching refs:num_threads

78     thread_index_t num_threads;
95 * @param num_threads Number of threads that are allowed to work on
101 Comparator comp, thread_index_t num_threads)
103 _GLIBCXX_PARALLEL_ASSERT(num_threads > 0);
136 begin, end - 1, pred, num_threads);
159 * @param num_threads
166 thread_index_t iam, thread_index_t num_threads,
175 if (num_threads <= 1 || n <= 1)
186 difference_type split_pos = qsb_divide(begin, end, comp, num_threads);
194 num_threads - 1, split_pos * num_threads / n));
200 # pragma omp parallel num_threads(2)
223 num_threads - num_threads_leftside,
253 thread_index_t num_threads = tl.num_threads;
378 victim = rng(num_threads);
413 * @param num_threads Number of threads that are allowed to work on
420 thread_index_t num_threads)
437 if (num_threads > n)
438 num_threads = static_cast<thread_index_t>(n);
441 tls_type** tls = new tls_type*[num_threads];
442 difference_type queue_size = num_threads * (thread_index_t)(log2(n) + 1);
443 for (thread_index_t t = 0; t < num_threads; ++t)
451 for (int i = 0; i < num_threads; ++i)
454 tls[i]->num_threads = num_threads;
462 qsb_conquer(tls, begin, begin + n, comp, 0, num_threads, true);
467 for (int i = 1; i < num_threads; ++i)
471 for (int i = 0; i < num_threads; ++i)