vs2010 sample for c++ [1] CThreadPool

 

 

msdn 에서 제공하는 c++ 용 샘플코드

관심있는 사람은 보겠지만

비쥬얼 스튜디오를 실행하면 나오는 시작페이지에는 여러 즐거운? 내용들이 많이있다.

 

그중에 샘플을 프로젝트들을 제공하기도 한다 .

http://archive.msdn.microsoft.com/vcsamples

요 내용들을 가지고 놀아보자

 

아무거나 보다보니 ThreadPool 이 있더라

근데 샘플인데 코드에 탭들이 ..정말 장난 아님 ..

보면 atl 라이브러리 에 등록된 CTrheadPool 을 이용한다.

 

정리하자면   생성-> 작업등록 -> 작업 기다림 ->파괴

인데  아래 샘플에는 작업 의 모두 성공의 기다림은 없고 모두 파괴이다.

 

CthreadPool 템플릿에 CmyWorker  작업클래스 기준하여 생성

CreateTasks 를통하여 CTaskBase 자료 클래스 생성 하여 전달

QueueRequest  함수통하여 스레드풀에 입력

그냥 슬립으로 기다림 후 태스크 자료 클래스 해제후 shutdown 끝

 

뭐 그냥 코딩 해서 써두 되지만 atl CthreadPool 을쓰면 

작업처리 스레드 갯수 설정이 쉽고 작업 을 입력하는데 있어서 매우 편리하다.

 

알고 있다고 생각하며 코딩 을하지만 실제로 쓰지 않는경우가 많다.. 익숙하지 않아서..

그러므로 자주봐야겟지 이것저것.

 

 

아래코드

---

ThreadPool.cpp int main(int /*argc*/, char* /*argv[]*/) {  CThreadPool<CMyWorker> pool;  CTaskArray tasks;  HRESULT hr = pool.Initialize((void*)321, THREADPOOL_SIZE);    if( SUCCEEDED( hr ) ) {   int i = -1;   CTaskBase* pTask = NULL;   if ( CreateTasks(tasks, 100) ) {    for ( i = 0; i < tasks.GetSize(); i++ ) {     pTask = tasks[ i ];     ATLASSERT( NULL != pTask );     pool.QueueRequest( (CMyWorker::RequestType) pTask );    }   }   // Allow a little time for all the tasks to complete   Sleep(1000);   // Clean up the tasks and shutdown the thread pool   for ( i = 0; i < tasks.GetSize(); i++ ) {    pTask = tasks[ i ];    ATLASSERT( NULL != pTask );    delete pTask;   }   // Shutdown the thread pool   pool.Shutdown();  }  else   printf("Failed to init thread pool!");  printf("\n");  return 0; }   tasks.h #pragma once /////////////////////////////////////////////////////////////////////////////// class CTaskBase { public:  virtual void DoTask(void *pvParam, OVERLAPPED *pOverlapped)=0; }; /////////////////////////////////////////////////////////////////////////////// class CTask1 : public CTaskBase { public:  virtual void DoTask(void *pvParam, OVERLAPPED *pOverlapped)  {   printf("[%d]: CTask1::DoTask(pvParam=%d, pOverlapped=%d)\n",    ::GetCurrentThreadId(), (DWORD_PTR)pvParam, (DWORD_PTR)pOverlapped);  } }; /////////////////////////////////////////////////////////////////////////////// class CTask2 : public CTaskBase { public:  virtual void DoTask(void *pvParam, OVERLAPPED *pOverlapped)  {   printf("[%d]: CTask2::DoTask(pvParam=%d, pOverlapped=%d)\n",    ::GetCurrentThreadId(), (DWORD_PTR)pvParam, (DWORD_PTR)pOverlapped);  } }; /////////////////////////////////////////////////////////////////////////////// typedef CSimpleArray<CTaskBase*> CTaskArray; /////////////////////////////////////////////////////////////////////////////// bool CreateTasks(CTaskArray& tasks, DWORD dwCount) {  bool bOk = false;  if ( 0 == tasks.GetSize() && dwCount > 0 ) {   CTaskBase* pTask = NULL;   for ( DWORD i = 0; i < dwCount; i++ ) {    if ( i % 2 )     pTask = new CTask1;    else     pTask = new CTask2;    if ( !tasks.Add( pTask ))     ATLASSERT( false );   }   bOk = true;  }  return bOk; } Worker.h #pragma once LONG g_lCurrId = -1; class CMyWorker { public:     typedef DWORD_PTR RequestType;  CMyWorker() : m_dwExecs( 0 )  {   m_lId = InterlockedIncrement( &g_lCurrId );  }     virtual BOOL Initialize(void *pvParam)     {   printf("[%d]: CMyWorker.Initialize(%d)\n", (DWORD_PTR)::GetCurrentThreadId(), (DWORD_PTR)pvParam );   return TRUE;     }     virtual void Terminate(void* /*pvParam*/)     {   printf( "CMyWorker #%d exec'd %d times.\n", m_lId, m_dwExecs );  }  void Execute(RequestType dw, void *pvParam, OVERLAPPED* pOverlapped) throw()     {         ATLASSERT(pvParam != NULL);   printf("[%d] CMyWorker::Execute(dw=%d, pvParam=%d, pOverlapped=%d\n",    ::GetCurrentThreadId(), dw, (DWORD_PTR)pvParam, (DWORD_PTR)pOverlapped);   CTaskBase* pTask = (CTaskBase*)(DWORD_PTR)dw;   pTask->DoTask(pvParam, pOverlapped);   m_dwExecs++;  }     virtual BOOL GetWorkerData(DWORD /*dwParam*/, void ** /*ppvData*/)     {         return FALSE;     } protected:  DWORD m_dwExecs;  LONG m_lId; }; // CMyWorker

 

---