An enumeration indicating the state of the queue after a push.
The type of push/emplace you want to execute.
Defined in “ark/concurrency/forward.hh”:
- using ThreadPoolPtr = std::shared_ptr< ThreadPool >
A simple wrapper around futexes that allows you to wait on a condition (this class) until it is notified/signaled. It works without a mutex. If you signal the class, it will remain signaled until wait() is called.
This class allows you to create a backing thread that will process commands. It is useful for when you have code where all commands need to execute from the same thread context.
A lock-free/wait-free/alloc-free multi-producer/multi-subscriber queue, which favors newer items over older items. This is optimized to allow consumers to make progress at all costs, even when crossing thread priority boundaries.
It is primarily intended for situations in which you might have different priority threads pushing and popping. It will most likely be a bit slower than a typical mutex/queue pair, but is aimed at preventing priority inversion.
A basic thread pool, which allows you to schedule concrete work items (functions) over some number of threads.
Configuration for the thread pool. Can be used to configure some advanced features of the pool.
A structure intended to allow explicit management of thread priorities within the pool.
A structure used to give some basic statistics about the running thread pool.
Declared in “ark/concurrency/lockless_queue.hh”:
constexpr LocklessQueuePushOptions operator|(LocklessQueuePushOptions lhs, LocklessQueuePushOptions rhs)
Operator for or-ing an option to the list.
constexpr LocklessQueuePushOptions operator&(LocklessQueuePushOptions lhs, LocklessQueuePushOptions rhs)
Operator for and-ing an option to the list.