|
Aleph-w 3.0
A C++ Library for Data Structures and Algorithms
|
Public Member Functions | |
| void | run () override |
| this is a item extracted from the queue | |
Public Member Functions inherited from QueueTheadsPool< T >::ConsumerQueueEvent | |
| size_t | get_count () const noexcept |
| void | increment_count () noexcept |
| virtual | ~ConsumerQueueEvent () |
Additional Inherited Members | |
Public Attributes inherited from QueueTheadsPool< T >::ConsumerQueueEvent | |
| T | item |
Protected Attributes inherited from QueueTheadsPool< T >::ConsumerQueueEvent | |
| std::atomic< size_t > | count = 0 |
Definition at line 48 of file test-con-queue.C.
|
inlineoverridevirtual |
this is a item extracted from the queue
Derived classes from this one implement the action that must performed when the item is extracted from the queue.
After event execution this event return a bool. A true return value indicates that the thread can continue consuming others items form the queue. At the contrary, a false return value indicates that the thread must finish
Implements QueueTheadsPool< T >::ConsumerQueueEvent.
Definition at line 50 of file test-con-queue.C.
References QueueTheadsPool< T >::ConsumerQueueEvent::increment_count(), and WORK_DELAY_MS.