|
Aleph-w 3.0
A C++ Library for Data Structures and Algorithms
|
Common configuration object for parallel algorithms. More...
#include <thread_pool.H>
Public Attributes | |
| size_t | min_size = 0 |
| Run sequentially below this size. | |
| size_t | chunk_size = 0 |
| Elements per chunk (0 = auto). | |
| size_t | max_tasks = 0 |
| Maximum number of scheduled tasks (0 = auto). | |
| ThreadPool * | pool = nullptr |
| Executor to use (nullptr = default_pool()). | |
| CancellationToken | cancel_token {} |
| Cooperative cancellation observer. | |
Common configuration object for parallel algorithms.
Existing overloads that take ThreadPool& and chunk_size remain valid. This object provides a more coherent way to pass tuning and control knobs without widening every signature further.
Definition at line 352 of file thread_pool.H.
| CancellationToken Aleph::ParallelOptions::cancel_token {} |
Cooperative cancellation observer.
Definition at line 358 of file thread_pool.H.
| size_t Aleph::ParallelOptions::chunk_size = 0 |
Elements per chunk (0 = auto).
Definition at line 355 of file thread_pool.H.
Referenced by TEST_F().
| size_t Aleph::ParallelOptions::max_tasks = 0 |
Maximum number of scheduled tasks (0 = auto).
Definition at line 356 of file thread_pool.H.
| size_t Aleph::ParallelOptions::min_size = 0 |
Run sequentially below this size.
Definition at line 354 of file thread_pool.H.
| ThreadPool* Aleph::ParallelOptions::pool = nullptr |
Executor to use (nullptr = default_pool()).
Definition at line 357 of file thread_pool.H.
Referenced by example_parallel_building_blocks(), example_parallel_enumerate(), example_parallel_map(), example_parallel_scan_merge_partition(), example_parallel_sort(), example_parallel_zip(), example_variadic_zip(), Aleph::pall(), Aleph::parallel_for(), Aleph::parallel_for_index(), Aleph::parallel_invoke(), Aleph::parallel_reduce(), Aleph::parallel_transform(), Aleph::pcount_if(), Aleph::penumerate_for_each(), Aleph::penumerate_for_each(), Aleph::penumerate_maps(), Aleph::pexclusive_scan(), Aleph::pexclusive_scan(), Aleph::pexists(), Aleph::pfilter(), Aleph::pfind(), Aleph::pfind_value(), Aleph::pfoldl(), Aleph::pfor_each(), Aleph::pfor_each(), Aleph::pmaps(), Aleph::pmax(), Aleph::pmin(), Aleph::ppartition(), Aleph::pscan(), Aleph::pscan(), Aleph::pzip_all_n(), Aleph::pzip_count_if_n(), Aleph::pzip_exists_n(), Aleph::pzip_foldl(), Aleph::pzip_foldl_n(), Aleph::pzip_for_each(), Aleph::pzip_for_each_n(), Aleph::pzip_maps(), Aleph::pzip_maps_n(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), and TEST_F().