The C++ framework for developing highly scalable, high performance servers on Windows platforms.

• Home
• What
• Why
• How
• Who
• Products
• Pricing
• Blog
• Contact

Search

CThreadSafeRingBufferWorkPool Class Reference

Inheritance diagram for CThreadSafeRingBufferWorkPool:

[legend]

Collaboration diagram for CThreadSafeRingBufferWorkPool:

[legend]

List of all members.

Public Types
typedef unsigned short	ThreadCount
typedef ThreadIdentifier	ThreadIdentifier
Public Member Functions
	CThreadSafeRingBufferWorkPool (size_t queueSize, ThreadCount numThreads, IRingBufferWorkPoolThreadFactory &threadFactory)
	CThreadSafeRingBufferWorkPool (IMonitorThreadPool &monitor, size_t queueSize, ThreadCount numThreads, IRingBufferWorkPoolThreadFactory &threadFactory)
	CThreadSafeRingBufferWorkPool (const CThreadSafeRingBufferWorkPool &rhs)
	~CThreadSafeRingBufferWorkPool () override
CThreadSafeRingBufferWorkPool &	operator= (const CThreadSafeRingBufferWorkPool &rhs)
void	SetThreadName (const _tstring &threadName) const
void	Start ()
void	BeginShutdown ()
void	WaitForShutdownToComplete ()
void	Dispatch (const BYTE *const pData, DWORD dataLength)
void	DispatchEx (const Data data[], const DWORD numEntries)
Classes
class	WorkerThread

---

Member Typedef Documentation

typedef unsigned short ThreadCount

typedef ThreadIdentifier ThreadIdentifier

Reimplemented from IManageThreadPoolThreads.

---

Constructor & Destructor Documentation

CThreadSafeRingBufferWorkPool	(	size_t	queueSize,
		ThreadCount	numThreads,
		IRingBufferWorkPoolThreadFactory &	threadFactory
	)

CThreadSafeRingBufferWorkPool	(	IMonitorThreadPool &	monitor,
		size_t	queueSize,
		ThreadCount	numThreads,
		IRingBufferWorkPoolThreadFactory &	threadFactory
	)

CThreadSafeRingBufferWorkPool

(

const CThreadSafeRingBufferWorkPool &

rhs

)

~CThreadSafeRingBufferWorkPool

(

)

[override]

---

Member Function Documentation

CThreadSafeRingBufferWorkPool& operator=

(

const CThreadSafeRingBufferWorkPool &

rhs

)

void SetThreadName

(

const _tstring &

threadName

)

const

void Start

(

)

void BeginShutdown

(

)

void WaitForShutdownToComplete

(

)

void Dispatch	(	const BYTE *const	pData,
		DWORD	dataLength
	)

void DispatchEx	(	const Data	data[],
		const DWORD	numEntries
	)

---