如何在C++中实现线程池？

Question

我试图将一个C#线程池移植到C++中，但遇到了一些严重的问题。C#线程池的一些特性是：

1. 显式定义并发线程的最大数目。
2. 每个线程都使用一个AutoResetEvent定义。
3. 线程中的每个工作项都会被重载，这样它就可以将委托函数作为其私有成员。

例如,

private static void RunOrBlock(WorkItem workitem) {
  workItem.ThreadIndex = WaitHandle.WaitAny(threadUnoccupied);
  ThreadPool.QueueUserWorkItem(threadWorker, workItem);
}

private static void threadWorker(object o) {
  WorkItem workItem = (workItem) o;
  workItem.Run();
  threadUnoccupied[workItem.ThreadIndex].Set();
}

WorkItem被定义为：

public abstract class WorkItem {
  protected int threadIndex;
  public abstract void Run();
  public int ThreadIndex {
    get { return threadIndex; }
    set { threadIndex = value; } 
  }

是否有人知道是否存在具有类似功能的开源线程池？如果没有，那么实现这样一个线程池的正确方法是什么？谢谢!

Answer 1

我不确定它们的具体功能，但是对于c++中的开源线程池，请看boost螺纹池或锌丝。

如果您只需要一个类似线程池的功能，并且有一个支持它的编译器，那么您也可以使用openmp 3.0 tasks。如果可能的话，这就是我的选择，因为"boost" threadpool看上去不太有说服力(因此可能会有相当大的开销)，而且似乎zthreads已经不再积极开发了(至少乍一看，我还不能百分之百确定)。

不完全是foss，但如果您能够接受许可(或者准备投资相当多的资金.)，Intel Threading Building Blocks可能是可用的。