如何获得第二个System.Thread.ThreadPool？

Question

如果我以嵌套方式使用 ThreadPool，我的应用程序将挂起：

 ThreadPool.QueueUserWorkItem((state) =>
      ThreadPool.QueueUserWorkItem(Action));

如何获取第二个独立的 ThreadPool 来实现嵌套？

Answer 1

只有一个 ThreadPool - 您不能（或应该）在应用程序中创建多个实例。

我不建议这样做，但如果您确实愿意，可以使用自己的 ThreadPool 实现的多个实例，例如 SmartThreadPool。从技术上讲，这将允许单独的“线程池”。

但是，我怀疑您挂起是由于死锁，而不是由于线程池的使用。我会调查一下你的困境在哪里。如果您安装了 VS 2010 beta 的副本，VS2010 并发可视化工具对此非常有用。

Answer 2

您的应用程序可能会挂起，因为您正在将其填充到所有活动线程都在等待排队线程的程度。 （我假设原始线程正在等待它排队的工作项完成。）

默认情况下，ThreadPool 有 25 *（CPU 数量）个工作线程 (IIRC)。

您可能想要重新调整项目的排队方式。如果您将它们排队，然后完成并退出线程，那就没问题，但是让工作项挂在等待其他进程上通常是一个糟糕的设计；如果这就是您正在做的事情，您可能需要使用真正的线程或完全不同的设计。使用真正的线程可能也是一个同样糟糕的主意，因为所有这一切（根据我对你的使用情况的推测）只会创建大量线程，这对你的性能没有任何好处。

更好的设计可能是拥有某种队列或堆栈，其中一些（2-4 个，具体取决于 CPU 数量）工作线程将项目添加到其中并弹出项目以进行工作。如果一个项目需要对一个新项目进行排队，它只需将其添加到堆栈中（如果需要等待另一个项目，则通过某种依赖性跟踪将自身添加回堆栈）。

Answer 3

您使用了错误的工具。

在 .NET 4.0 中，他们引入了任务并行库。这允许您执行诸如使用多个主题池以及在工作项之间建立父子关系之类的操作。

从 Task 类开始，它取代了 ThreadPool.QueueUserWorkItem。

http://msdn.microsoft .com/en-us/library/system.threading.tasks.task(VS.100).aspx

编辑

使用任务和任务调度程序创建自己的线程池的示例。

http://msdn.microsoft.com/en-us /library/dd997413(VS.100).aspx

Answer 4

虽然 Windows API 允许多个进程中的线程池，.NET 不会直接公开它。在 .NET Framework 中......

每个 .NET AppDomain 仅有一个 .NET 线程池，而且绝对没有办法改变这一点。

因此，对于不同的应用程序域……同一进程中可能有不同的 .NET 线程池。

（注意：.NET 中使用的 Hill Climb 算法的启发式也是基于每个 .NET ThreadPool 确定的。这无法指定每种类型的最大工作线程数，具有不同工作负载的“每个应用程序域全局”线程池的缺点。）

Answer 5

有且只有一个线程池。

Answer 6

一种方法是使用 BlockingCollection。
这是我为其构建的类：

更新于 2018-04-23：

public class WorkerPool<T> : IDisposable
{
    BlockingCollection<T> queue = new BlockingCollection<T>();
    List<Task> taskList;
    private CancellationTokenSource cancellationToken;
    int maxWorkers;
    private bool wasShutDown;

    int waitingUnits;

    public WorkerPool(CancellationTokenSource cancellationToken, int maxWorkers)
    {
        this.cancellationToken = cancellationToken;
        this.maxWorkers = maxWorkers;
        this.taskList = new List<Task>();
    }
    public void enqueue(T value)
    {
        queue.Add(value);
        waitingUnits++;
    }
    //call to signal that there are no more item
    public void CompleteAdding()
    {
        queue.CompleteAdding();          
    }

    //create workers and put then running
    public void startWorkers(Action<T> worker)
    {
        for (int i = 0; i < maxWorkers; i++)
        {
            taskList.Add(new Task(() =>
            {
                string myname = "worker " + Guid.NewGuid().ToString();

                try
                {
                    while (!cancellationToken.IsCancellationRequested)
                    {                     
                        var value = queue.Take();
                        waitingUnits--;
                        worker(value);
                    }
                }
                catch (Exception ex) when (ex is InvalidOperationException)  //throw when collection is closed with  CompleteAdding method. No pretty way to do this.
                {
                    //do nothing
                }
            }));
        }

        foreach (var task in taskList)
        {
            task.Start();
        }
    }

    //wait for all workers to be finish their jobs
    public void await()
    {
        while (waitingUnits >0 || !queue.IsAddingCompleted)
            Thread.Sleep(100);

        shutdown();
    }

    private void shutdown()
    {
        wasShutDown = true;
        Task.WaitAll(taskList.ToArray());            
    }

    //case something bad happen dismiss all pending work
    public void Dispose()
    {
        if (!wasShutDown)
        {
            queue.CompleteAdding();
            shutdown();
        }
    }
}

要查看它的工作原理，请构建此单元测试：

[TestMethod]
public void workerPoolTest()
{
    WorkerPool<int> workerPool = new WorkerPool<int>(new CancellationTokenSource(), 5);

    workerPool.startWorkers(value =>
    {
        log.Debug(value);
    });

    for (int i = 0; i < 100; i++)
    {
        workerPool.enqueue(i);
    }
    workerPool.CompleteAdding();
    workerPool.await();
}

现在您可以进行任意数量的民意调查，只需创建新的 WorkPool 对象。

请注意，代码尚未经过完全测试。