Public Member Functions | |
CThreadSafeRingBufferWorkQueue (size_t queueSize) | |
CThreadSafeRingBufferWorkQueue (const CThreadSafeRingBufferWorkQueue &rhs) | |
~CThreadSafeRingBufferWorkQueue () override | |
CThreadSafeRingBufferWorkQueue & | operator= (const CThreadSafeRingBufferWorkQueue &rhs) |
void | Shutdown () |
bool | IsFull () const |
void | AddWork (const void *pData, const DWORD dataLength) override |
void | AddWorkEx (const Data data[], DWORD numEntries) override |
bool | TryAddWork (const void *pData, DWORD dataLength) override |
bool | TryAddWorkEx (const Data data[], DWORD numEntries) override |
bool | GetWork (WorkItem &workItem, Milliseconds timeout=0) override |
bool | IsShutdown () const override |
virtual bool | GetWork (WorkItem &workItem, Milliseconds timeout=0)=0 |
Friends | |
class | IReadableRingBufferWorkQueue::WorkItem |
Classes | |
struct | RingBuffer |
CThreadSafeRingBufferWorkQueue | ( | size_t | queueSize | ) | [explicit] |
CThreadSafeRingBufferWorkQueue | ( | const CThreadSafeRingBufferWorkQueue & | rhs | ) |
~CThreadSafeRingBufferWorkQueue | ( | ) | [override] |
CThreadSafeRingBufferWorkQueue& operator= | ( | const CThreadSafeRingBufferWorkQueue & | rhs | ) |
void Shutdown | ( | ) |
bool IsFull | ( | ) | const |
void AddWork | ( | const void * | pData, | |
const DWORD | dataLength | |||
) | [override, virtual] |
Implements IWritableRingBufferWorkQueue.
Implements IWritableRingBufferWorkQueue.
Implements IWritableRingBufferWorkQueue.
Implements IWritableRingBufferWorkQueue.
bool GetWork | ( | WorkItem & | workItem, | |
Milliseconds | timeout = 0 | |||
) | [override] |
bool IsShutdown | ( | ) | const [override, virtual] |
Implements IReadableRingBufferWorkQueue.
virtual bool GetWork | ( | WorkItem & | workItem, | |
Milliseconds | timeout = 0 | |||
) | [pure virtual, inherited] |
friend class IReadableRingBufferWorkQueue::WorkItem [friend] |