kcenon::thread::detail::lockfree_job_queue::node Struct Reference

Internal queue node structure. More...

Collaboration diagram for kcenon::thread::detail::lockfree_job_queue::node:

Public Member Functions
	node ()
	node (std::unique_ptr< job > &&job_data)

Public Attributes
std::unique_ptr< job >	data
std::atomic< node * >	next {nullptr}

Detailed Description

Internal queue node structure.

Nodes use atomic pointers for lock-free traversal. Each node holds one job (or nullptr for dummy node).

Definition at line 216 of file lockfree_job_queue.h.

Constructor & Destructor Documentation

node() [1/2]

kcenon::thread::detail::lockfree_job_queue::node::node ( )

inline

Definition at line 220 of file lockfree_job_queue.h.

: data(nullptr), next(nullptr) {}

node() [2/2]

kcenon::thread::detail::lockfree_job_queue::node::node ( std::unique_ptr< job > && job_data )

inlineexplicit

Definition at line 222 of file lockfree_job_queue.h.

            : data(std::move(job_data))
            , next(nullptr) {}

Member Data Documentation

data

std::unique_ptr<job> kcenon::thread::detail::lockfree_job_queue::node::data

Definition at line 217 of file lockfree_job_queue.h.

Referenced by kcenon::thread::detail::lockfree_job_queue::node_pool::acquire(), kcenon::thread::detail::lockfree_job_queue::dequeue(), and kcenon::thread::detail::lockfree_job_queue::node_pool::release().

next

std::atomic<node*> kcenon::thread::detail::lockfree_job_queue::node::next {nullptr}

Definition at line 218 of file lockfree_job_queue.h.

{nullptr};   // Next node in queue

Referenced by kcenon::thread::detail::lockfree_job_queue::node_pool::acquire(), kcenon::thread::detail::lockfree_job_queue::dequeue(), kcenon::thread::detail::lockfree_job_queue::empty(), kcenon::thread::detail::lockfree_job_queue::enqueue(), kcenon::thread::detail::lockfree_job_queue::node_pool::release(), and kcenon::thread::detail::lockfree_job_queue::node_pool::~node_pool().

---

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

• include/kcenon/thread/lockfree/lockfree_job_queue.h