Thrill
0.1
|
Parallel Super Scalar String Sample Sort Context.
Definition at line 94 of file parallel_sample_sort.hpp.
Inherits Parameters.
#include <parallel_sample_sort.hpp>
Public Member Functions | |
PS5Context (size_t _thread_num) | |
context constructor More... | |
void | donesize (size_t n) |
decrement number of unordered strings More... | |
template<typename StringPtr > | |
void | enqueue (PS5SortStep *sstep, const StringPtr &strptr, size_t depth) |
enqueue a new job in the thread pool More... | |
size_t | sequential_threshold () |
return sequential sorting threshold More... | |
Public Attributes | |
std::atomic< size_t > | base_sort_steps |
MultiTimer | mtimer |
timers for individual sorting steps More... | |
size_t | num_threads |
number of threads overall More... | |
std::atomic< size_t > | para_ss_steps |
counters More... | |
std::atomic< size_t > | rest_size |
number of remaining strings to sort More... | |
std::atomic< size_t > | sequ_ss_steps |
ThreadPool | threads_ |
thread pool More... | |
size_t | total_size |
total size of input More... | |
|
inline |
context constructor
Definition at line 116 of file parallel_sample_sort.hpp.
|
inline |
decrement number of unordered strings
Definition at line 138 of file parallel_sample_sort.hpp.
References PS5ParametersDefault::enable_rest_size.
void enqueue | ( | PS5SortStep * | sstep, |
const StringPtr & | strptr, | ||
size_t | depth | ||
) |
enqueue a new job in the thread pool
Definition at line 1394 of file parallel_sample_sort.hpp.
References PS5ParametersDefault::enable_parallel_sample_sort, StringPtr< StringSet_ >::size(), and PS5ParametersDefault::use_only_first_sortstep.
|
inline |
return sequential sorting threshold
Definition at line 127 of file parallel_sample_sort.hpp.
References PS5ParametersDefault::enable_rest_size, max(), PS5ParametersDefault::smallsort_threshold, and thrill::core::hyperloglog::threshold().
std::atomic<size_t> base_sort_steps |
Definition at line 104 of file parallel_sample_sort.hpp.
MultiTimer mtimer |
timers for individual sorting steps
Definition at line 107 of file parallel_sample_sort.hpp.
size_t num_threads |
number of threads overall
Definition at line 110 of file parallel_sample_sort.hpp.
std::atomic<size_t> para_ss_steps |
counters
Definition at line 104 of file parallel_sample_sort.hpp.
std::atomic<size_t> rest_size |
number of remaining strings to sort
Definition at line 101 of file parallel_sample_sort.hpp.
std::atomic<size_t> sequ_ss_steps |
Definition at line 104 of file parallel_sample_sort.hpp.
ThreadPool threads_ |
thread pool
Definition at line 113 of file parallel_sample_sort.hpp.
size_t total_size |
total size of input
Definition at line 98 of file parallel_sample_sort.hpp.