|
Aleph-w 3.0
A C++ Library for Data Structures and Algorithms
|
This is the complete list of members for Aleph::ThreadPool, including all inherited members.
| active_tasks | Aleph::ThreadPool | private |
| condition | Aleph::ThreadPool | private |
| enqueue(F &&f, Args &&... args) -> std::future< std::invoke_result_t< F, Args... > > | Aleph::ThreadPool | inline |
| enqueue_batch(F &&f, const Container &args_list) -> std::vector< std::future< decltype(std::apply(f, *std::begin(args_list)))> > | Aleph::ThreadPool | inline |
| enqueue_bounded(F &&f, Args &&... args) -> std::future< std::invoke_result_t< F, Args... > > | Aleph::ThreadPool | inline |
| enqueue_bounded_detached(F &&f, Args &&... args) | Aleph::ThreadPool | inline |
| enqueue_bulk(F &&f, const Container &args_container) -> std::vector< std::future< std::invoke_result_t< F, typename Container::value_type > > > | Aleph::ThreadPool | inline |
| enqueue_detached(F &&f, Args &&... args) | Aleph::ThreadPool | inline |
| exception_callback_ | Aleph::ThreadPool | private |
| get_queue_limits() const | Aleph::ThreadPool | inline |
| get_stats() const | Aleph::ThreadPool | inline |
| hard_limit_ | Aleph::ThreadPool | private |
| idle_condition | Aleph::ThreadPool | private |
| is_idle() const | Aleph::ThreadPool | inline |
| is_stopped() const noexcept | Aleph::ThreadPool | inline |
| make_invocable(F &&f, Args &&... args) | Aleph::ThreadPool | inlineprivatestatic |
| num_threads() const noexcept | Aleph::ThreadPool | inline |
| operator=(const ThreadPool &)=delete | Aleph::ThreadPool | |
| operator=(ThreadPool &&)=delete | Aleph::ThreadPool | |
| peak_queue_size_ | Aleph::ThreadPool | private |
| pending_tasks() const | Aleph::ThreadPool | inline |
| queue_mutex | Aleph::ThreadPool | mutableprivate |
| reset_stats() | Aleph::ThreadPool | inline |
| resize(size_t new_size) | Aleph::ThreadPool | inline |
| running_tasks() const noexcept | Aleph::ThreadPool | inline |
| set_exception_callback(ExceptionCallback callback) | Aleph::ThreadPool | inline |
| set_queue_limits(size_t soft_limit, size_t hard_limit=std::numeric_limits< size_t >::max()) | Aleph::ThreadPool | inline |
| shutdown() | Aleph::ThreadPool | inline |
| soft_limit_ | Aleph::ThreadPool | private |
| space_available | Aleph::ThreadPool | private |
| start_workers(size_t n) | Aleph::ThreadPool | inlineprivate |
| stop | Aleph::ThreadPool | private |
| stop_workers() | Aleph::ThreadPool | inlineprivate |
| tasks | Aleph::ThreadPool | private |
| tasks_completed_ | Aleph::ThreadPool | private |
| tasks_failed_ | Aleph::ThreadPool | private |
| ThreadPool(size_t n_threads=std::thread::hardware_concurrency()) | Aleph::ThreadPool | inlineexplicit |
| ThreadPool(const ThreadPool &)=delete | Aleph::ThreadPool | |
| ThreadPool(ThreadPool &&)=delete | Aleph::ThreadPool | |
| try_enqueue(F &&f, Args &&... args) -> std::optional< std::future< std::invoke_result_t< F, Args... > > > | Aleph::ThreadPool | inline |
| try_enqueue_detached(F &&f, Args &&... args) | Aleph::ThreadPool | inline |
| wait_all(std::chrono::milliseconds poll_interval=std::chrono::milliseconds(1)) | Aleph::ThreadPool | inline |
| wait_all_for(std::chrono::duration< Rep, Period > timeout) | Aleph::ThreadPool | inline |
| wait_all_until(std::chrono::time_point< Clock, Duration > deadline) | Aleph::ThreadPool | inline |
| worker_loop() | Aleph::ThreadPool | inlineprivate |
| workers | Aleph::ThreadPool | private |
| ~ThreadPool() | Aleph::ThreadPool | inline |