#pragma once
|
|
#include "MemoryPool.h"
|
|
class AFX_EXT_CLASS CIOCPHandler : public CMemoryPool
|
{
|
public:
|
CIOCPHandler(void);
|
virtual ~CIOCPHandler(void);
|
|
BOOL Create(int nMaxNumberOfConcurrentThreads=0, int* pnOutErrCode=NULL); //!< IOCP »ý¼º ¹× ÃʱâÈ
|
BOOL Associate(SOCKET hSocket, ULONG_PTR CompletionKey, int* pnOutErrCode=NULL); //!< ¼ÒÄÏ°ú IOCP ¿Í ¿¬°á
|
BOOL Associate(HANDLE hDevice, ULONG_PTR CompletionKey, int* pnOutErrCode=NULL); //!< ÆÄÀÏ ÇÚµé°ú IOCP ¿ÍÀÇ ¿¬°á
|
BOOL PostCompletionStatus(ULONG_PTR CompleitonKey, DWORD dwBytesTransferred=0, OVERLAPPED* pOverlapped=NULL, int* pnOutErrCode=NULL); //!< IO Completion Queue¿¡ ÇÑ ¿Ï·á ·¹Äڵ带 »ç¿ëÀÚ Á¤ÀÇ·Î Ãß°¡
|
BOOL GetCompletionStatus(ULONG_PTR* pOutCompletionKey, LPDWORD pdwOutBytesTransferred, LPOVERLAPPED* pOutOverlapped, int* pnOutErrCode=NULL, DWORD dwWaitingTime=INFINITE); //!< IO Completion Queue¿¡¼ ¿Ï·á ÆÐŶÀ» ¾ò¾î¿Â´Ù.
|
BOOL CreateThreadPool(IIOCPProcessThread* piProcessThread, int nNumOfPooledThread=0); //!< IOCP Worker Thread Ç®À» ¸¸µë
|
void CloseAllThreads(void); // ÇöÀç µ¹°í ÀÖ´Â ¾²·¹µå ¸ðµÎ Á×ÀÓ
|
|
virtual void ProcessingThread() = 0; //!< Processing Thread ¼ø¼ö °¡»ó ÇÔ¼ö
|
|
private:
|
static DWORD __stdcall IocpWorkerThreadStartingPoint(PVOID pvParam); ///< IOCP ¿öÄ¿ ¾²·¹µå ½ÃÀÛ Æ÷ÀÎÆ®·Î¼¸¸ÀÇ ¿ªÈ°
|
|
private:
|
HANDLE m_hIOCP; ///< IOCP Ä¿³Î °´Ã¼¿¡ ´ëÇÑ ÇÚµé
|
int m_nCreatedThreadNumber; ///< ¸¸µé¾îÁø Worker Thread ¼ö
|
|
protected:
|
volatile LONG m_nLiveThreadNum; ///< ÇöÀç »ì¾ÆÀÖ´Â ¿öÄ¿ ¾²·¹µå ¼ö
|
HANDLE m_EventExitWorkerThread; ///< ¿öÄ¿ ¾²·¹µå Á¾·áÀÇ À̺¥Æ® Çڵ鷯
|
};
|
