게임서버 만들기 3

#ifndef __CompletionHandler_H #define __CompletionHandler_H #include "WorkerThread.h" class CompletionHandler { public: static CompletionHandler* getInstance(); static void releaseInstance(); bool initialize(); HANDLE getWorkerIOCPHandle(); bool addHandleToIOCP(HANDLE handle, DWORD keyValue); private: CompletionHandler(void); virtual ~CompletionHandler(void); static CompletionHandler* selfInstance; HANDLE handleWorkerIOCP; WorkerThread* workerThread[WorkerThreadCount]; }; #endif #include "CompletionHandler.h" CompletionHandler* CompletionHandler::selfInstance = 0; CompletionHandler::CompletionHandler(void) :handleWorkerIOCP(0) { } CompletionHandler::~CompletionHandler(void) { int i; for(i = 0; i< WorkerThreadCount; i++) delete workerThread[i]; } CompletionHandler* CompletionHandler::getInstance() { if(selfInstance == 0) selfInstance = new CompletionHandler(); return selfInstance; } void CompletionHandler::releaseInstance() { if(selfInstance != 0) { delete selfInstance; selfInstance = 0; } } bool CompletionHandler::initialize() { handleWorkerIOCP = CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0,0, WorkerThreadCount); if(handleWorkerIOCP ==0) return false; int i; for(i = 0; i< WorkerThreadCount; i++) { workerThread[i] = new workerThread(); workerThread[i]->begin(); } return true; } HANDLE CompletionHandler::getWorkerIOCPHandle() { return handleWorkerIOCP; } bool CompletionHandler::addHandleToIOCP( HANDLE handle, DWORD keyValue ) { CreateCompletionPort(handle, handleWorkerIOCP, keyValue, 0); return true; }