Aleph-w 3.0
A C++ Library for Data Structures and Algorithms
Loading...
Searching...
No Matches
Aleph::ThreadPool Member List

This is the complete list of members for Aleph::ThreadPool, including all inherited members.

active_tasksAleph::ThreadPoolprivate
conditionAleph::ThreadPoolprivate
enqueue(F &&f, Args &&... args) -> std::future< std::invoke_result_t< F, Args... > >Aleph::ThreadPoolinline
enqueue_batch(F &&f, const Container &args_list) -> std::vector< std::future< decltype(std::apply(f, *std::begin(args_list)))> >Aleph::ThreadPoolinline
enqueue_bounded(F &&f, Args &&... args) -> std::future< std::invoke_result_t< F, Args... > >Aleph::ThreadPoolinline
enqueue_bounded_detached(F &&f, Args &&... args)Aleph::ThreadPoolinline
enqueue_bulk(F &&f, const Container &args_container) -> std::vector< std::future< std::invoke_result_t< F, typename Container::value_type > > >Aleph::ThreadPoolinline
enqueue_detached(F &&f, Args &&... args)Aleph::ThreadPoolinline
exception_callback_Aleph::ThreadPoolprivate
get_queue_limits() constAleph::ThreadPoolinline
get_stats() constAleph::ThreadPoolinline
hard_limit_Aleph::ThreadPoolprivate
idle_conditionAleph::ThreadPoolprivate
is_idle() constAleph::ThreadPoolinline
is_stopped() const noexceptAleph::ThreadPoolinline
make_invocable(F &&f, Args &&... args)Aleph::ThreadPoolinlineprivatestatic
num_threads() const noexceptAleph::ThreadPoolinline
operator=(const ThreadPool &)=deleteAleph::ThreadPool
operator=(ThreadPool &&)=deleteAleph::ThreadPool
peak_queue_size_Aleph::ThreadPoolprivate
pending_tasks() constAleph::ThreadPoolinline
queue_mutexAleph::ThreadPoolmutableprivate
reset_stats()Aleph::ThreadPoolinline
resize(size_t new_size)Aleph::ThreadPoolinline
running_tasks() const noexceptAleph::ThreadPoolinline
set_exception_callback(ExceptionCallback callback)Aleph::ThreadPoolinline
set_queue_limits(size_t soft_limit, size_t hard_limit=std::numeric_limits< size_t >::max())Aleph::ThreadPoolinline
shutdown()Aleph::ThreadPoolinline
soft_limit_Aleph::ThreadPoolprivate
space_availableAleph::ThreadPoolprivate
start_workers(size_t n)Aleph::ThreadPoolinlineprivate
stopAleph::ThreadPoolprivate
stop_workers()Aleph::ThreadPoolinlineprivate
tasksAleph::ThreadPoolprivate
tasks_completed_Aleph::ThreadPoolprivate
tasks_failed_Aleph::ThreadPoolprivate
ThreadPool(size_t n_threads=std::thread::hardware_concurrency())Aleph::ThreadPoolinlineexplicit
ThreadPool(const ThreadPool &)=deleteAleph::ThreadPool
ThreadPool(ThreadPool &&)=deleteAleph::ThreadPool
try_enqueue(F &&f, Args &&... args) -> std::optional< std::future< std::invoke_result_t< F, Args... > > >Aleph::ThreadPoolinline
try_enqueue_detached(F &&f, Args &&... args)Aleph::ThreadPoolinline
wait_all(std::chrono::milliseconds poll_interval=std::chrono::milliseconds(1))Aleph::ThreadPoolinline
wait_all_for(std::chrono::duration< Rep, Period > timeout)Aleph::ThreadPoolinline
wait_all_until(std::chrono::time_point< Clock, Duration > deadline)Aleph::ThreadPoolinline
worker_loop()Aleph::ThreadPoolinlineprivate
workersAleph::ThreadPoolprivate
~ThreadPool()Aleph::ThreadPoolinline