stapl::runtime::task_queue< R(Args...)> Class Template Reference

A lock-free MPSC (multiple producer, single consumer) queue of tasks to be executed. More...

Public Member Functions
bool	empty (void) const noexcept
template<typename Function >
void	add (Function &&f)
	Adds a new task to the queue.
template<typename... T>
bool	drain (T &&... t)
	Executes all pending tasks. More...

Detailed Description

template<typename R, typename... Args>
class stapl::runtime::task_queue< R(Args...)>

A lock-free MPSC (multiple producer, single consumer) queue of tasks to be executed.

The tasks are kept in an lock-free singly linked list in reversed order. Each node of the list is heap-allocated, since the type of the task is type-erased.

When drain(args...) is called, the list is reversed and the tasks are called with args... in the same order they were added to the queue.

Member Function Documentation

drain()

template<typename R , typename... Args>

template<typename... T>

bool stapl::runtime::task_queue< R(Args...)>::drain

(

T &&...

t

)

Executes all pending tasks.

This function will only execute the pending tasks when the function is called. If any tasks are added while drain() is executing, then they will not be executed.

Parameters

t	Arguments to pass to the pending tasks.

Returns

true if there were pending tasks, otherwise false.

---

The documentation for this class was generated from the following file:

• task_queue.hpp