Lines Matching refs:num_threads
69 thread_index_t num_threads;
144 seqs(sd->num_threads);
145 for (thread_index_t s = 0; s < sd->num_threads; s++)
150 std::vector<SortingPlacesIterator> offsets(sd->num_threads);
153 if (iam < sd->num_threads - 1)
157 for (int seq = 0; seq < sd->num_threads; seq++)
160 if (iam < (sd->num_threads - 1))
170 for (thread_index_t seq = 0; seq < sd->num_threads; seq++)
207 sd->samples + (num_samples * sd->num_threads),
212 for (thread_index_t s = 0; s < sd->num_threads; ++s)
227 if ((num_samples * (iam + 1)) < (num_samples * sd->num_threads))
349 _Settings::get().sort_mwms_oversampling * sd->num_threads - 1;
356 for (thread_index_t s = 0; s < sd->num_threads; s++)
365 seq_vector_type seqs(sd->num_threads);
367 for (int s = 0; s < sd->num_threads; ++s)
393 * @param num_threads Number of threads to use.
400 thread_index_t num_threads)
414 if (num_threads > n)
415 num_threads = static_cast<thread_index_t>(n);
421 # pragma omp parallel num_threads(num_threads)
423 num_threads = omp_get_num_threads(); //no more threads than requested
427 sd.num_threads = num_threads;
430 sd.temporary = new value_type*[num_threads];
435 (_Settings::get().sort_mwms_oversampling * num_threads - 1)
436 * num_threads;
443 sd.offsets = new difference_type[num_threads - 1];
444 sd.pieces = new std::vector<Piece<difference_type> >[num_threads];
445 for (int s = 0; s < num_threads; ++s)
446 sd.pieces[s].resize(num_threads);
447 starts = sd.starts = new difference_type[num_threads + 1];
449 difference_type chunk_length = n / num_threads;
450 difference_type split = n % num_threads;
452 for (int i = 0; i < num_threads; ++i)
457 starts[num_threads] = pos;
