求好手给一个最简单线程池的例子

求高手给一个最简单线程池的例子

求高手给一个最简单线程池的例子

最好能运行，有关键的注释

如果有相关的好博客或者好文章也可以，谢谢帮助



------解决方案--------------------
http://www.codeproject.com/Articles/579294/A-Perfect-ThreadPool-in-Windows-Cplusplus
相当好的例子！
------解决方案--------------------

#ifndef _ThreadPool_H_

#define _ThreadPool_H_

#pragma warning(disable: 4530)

#pragma warning(disable: 4786)

#include <cassert>

#include <vector>

#include <queue>

#include <windows.h>

#include<iostream>

using namespace std;

class ThreadJob  //工作基类

{

public:

  //供线程池调用的虚函数

  virtual void DoJob(void *pPara) = 0;

};

class ThreadPool

{

public:

  //dwNum 线程池规模

  ThreadPool(DWORD dwNum = 4) : _lThreadNum(0), _lRunningNum(0) 

  {

    InitializeCriticalSection(&_csThreadVector);

    InitializeCriticalSection(&_csWorkQueue);

    _EventComplete = CreateEvent(0, false, false, NULL);

    _EventEnd = CreateEvent(0, true, false, NULL);

    _SemaphoreCall = CreateSemaphore(0, 0,  0x7FFFFFFF, NULL);

    _SemaphoreDel =  CreateSemaphore(0, 0,  0x7FFFFFFF, NULL);

    assert(_SemaphoreCall != INVALID_HANDLE_VALUE);

    assert(_EventComplete != INVALID_HANDLE_VALUE);

    assert(_EventEnd != INVALID_HANDLE_VALUE);

    assert(_SemaphoreDel != INVALID_HANDLE_VALUE);

    AdjustSize(dwNum <= 0 ? 4 : dwNum);

  }

  ~ThreadPool()

  {

    DeleteCriticalSection(&_csWorkQueue);

    CloseHandle(_EventEnd);

    CloseHandle(_EventComplete);

    CloseHandle(_SemaphoreCall);

    CloseHandle(_SemaphoreDel);

    vector<ThreadItem*>::iterator iter;

    for(iter = _ThreadVector.begin(); iter != _ThreadVector.end(); iter++)

    {

      if(*iter)

        delete *iter;

    }

    DeleteCriticalSection(&_csThreadVector);

  }

  //调整线程池规模

  int AdjustSize(int iNum)

  {

    if(iNum > 0)

    {

      ThreadItem *pNew;

      EnterCriticalSection(&_csThreadVector);

      for(int _i=0; _i<iNum; _i++)

      {

        _ThreadVector.push_back(pNew = new ThreadItem(this)); 

        assert(pNew);

        pNew->_Handle = CreateThread(NULL, 0, DefaultJobProc, pNew, 0, NULL);

        // set priority

        SetThreadPriority(pNew->_Handle, THREAD_PRIORITY_BELOW_NORMAL);

        assert(pNew->_Handle);

      }

      LeaveCriticalSection(&_csThreadVector);

    }

    else

    {

      iNum *= -1;

      ReleaseSemaphore(_SemaphoreDel,  iNum > _lThreadNum ? _lThreadNum : iNum, NULL);

    }

    return (int)_lThreadNum;

  }

  //调用线程池

  void Call(void (*pFunc)(void  *), void *pPara = NULL)

  {

    assert(pFunc);

    EnterCriticalSection(&_csWorkQueue);

    _JobQueue.push(new JobItem(pFunc, pPara));

    LeaveCriticalSection(&_csWorkQueue);

    ReleaseSemaphore(_SemaphoreCall, 1, NULL);

  }

  //调用线程池

  inline void Call(ThreadJob * p, void *pPara = NULL)

  {

    Call(CallProc, new CallProcPara(p, pPara));

  }

  //结束线程池, 并同步等待

  bool EndAndWait(DWORD dwWaitTime = INFINITE)