nwiocompletionport.h

这是我做的一个iocp的服务器端的测试代码

#pragma once

#include "NWWorkerThread.h" 
#include "IMessageProcess.h"
class CIOCompletionPort
{
public:
	explicit CIOCompletionPort( size_t maxConcurrency = 0);
	virtual ~CIOCompletionPort(void);
	//绑定驱动
	int BindDevice( HANDLE hDevice, ULONG_PTR completionKey );

	void PostStatus( ULONG_PTR completionKey, 
		DWORD dwNumBytes = 0, 
		OVERLAPPED *pOverlapped = 0 );

	DWORD GetStatus( ULONG_PTR *pCompletionKey, 
		PDWORD pdwNumBytes,
		OVERLAPPED **ppOverlapped );

	DWORD GetStatus( ULONG_PTR *pCompletionKey, 
		PDWORD pdwNumBytes,
		OVERLAPPED **ppOverlapped, 
		DWORD dwMilliseconds );
	//启动工作线程
	int StartWorkerThreads();
	int StopWorkerThreads();
	int InitWorkerThreads(int nThreadNumber,IMessageProcess * pcMessageProccess,CSocketServer * pcSockServer);
	int UninitWorkerThreads();
	static CIOCompletionPort * GetInstance()
	{
		return & m_Instance ;
	}
protected:
	static CIOCompletionPort m_Instance ;
private:

	HANDLE m_iocp;
	MyWorkerThreadList m_lsWorkerThreadList ;
	/*
	* No copies do not implement
	*/
	CIOCompletionPort( const CIOCompletionPort &rhs );
	CIOCompletionPort &operator=( const CIOCompletionPort &rhs );
};