36

好吧...我已经对该网站进行了公平的搜索，并阅读了许多有关此主题的帖子。我发现这个问题：Code for a simple thread pool in C#特别有用。

但是，似乎总是如此，我需要的东西略有不同。

我查看了 MSDN 示例并对其进行了一些调整以适应我的需要。我参考的例子在这里：http: //msdn.microsoft.com/en-us/library/3dasc8as (VS.80,printer).aspx

我的问题是这个。HttpWebRequest我有一组相当简单的代码，通过和WebResponse类加载网页并通过Stream. 我在一个线程中触发了这个方法，因为它需要执行很多次。该方法本身很短，但需要触发的次数（每次使用不同的数据）会有所不同。它可以是 1 到 200 之间的任何值。

我读过的所有内容似乎都表明该ThreadPool班级是主要候选人。这就是事情变得棘手的地方。我可能需要启动这个东西说 100 次，但我最多只能运行 3 个线程（对于这个特定任务）。

我试过MaxThreads在ThreadPool通孔上设置：

ThreadPool.SetMaxThreads(3, 3);

我并不完全相信这种方法是有效的。此外，我不想破坏将在其上运行的系统上运行的其他网站或程序。那么，通过限制 上的线程ThreadPool数，我可以确定这仅与我的代码和我的线程有关吗？

MSDN 示例使用事件驱动方法和调用WaitHandle.WaitAll(doneEvents);，这就是我这样做的方式。

所以我的问题的核心是，如何确保或指定可以为其代码运行的最大线程数，但让代码继续运行更多线程，因为之前的线程完成直到某个任意点？我以正确的方式解决这个问题吗？

真挚地，

杰森

好的，我添加了信号量方法并完全删除了ThreadPool代码。看起来很简单。我的信息来自：http ://www.albahari.com/threading/part2.aspx

正是这个例子向我展示了如何：

[下面的文字是从网站复制/粘贴]

容量为 one 的ASemaphore类似于 a Mutexor lock，只是它Semaphore没有“所有者”——它与线程无关。任何线程都可以调用Releasea Semaphore，而使用Mutexand lock，只有获得资源的线程才能释放它。

在以下示例中，十个线程执行一个循环，Sleep中间有一条语句。ASemaphore确保不超过三个线程可以Sleep一次执行该语句：

class SemaphoreTest
{
    static Semaphore s = new Semaphore(3, 3);  // Available=3; Capacity=3

    static void Main()
    {
        for (int i = 0; i < 10; i++)
            new Thread(Go).Start();
    }

    static void Go()
    {
        while (true)
        {
            s.WaitOne();

            Thread.Sleep(100);   // Only 3 threads can get here at once

            s.Release();
        }
    }
}
4

2 回答 2

32

注意：如果您将其限制为“3”只是为了不让运行您的应用程序的机器不堪重负，我会首先确保这是一个问题。线程池应该为你管理这个。另一方面，如果您不想压倒其他资源，请继续阅读！

您无法管理线程池的大小（或者关于它的任何事情）。

在这种情况下，我会使用信号量来管理对资源的访问。在您的情况下，您的资源正在运行网络抓取，或计算一些报告等。

为此，在您的静态类中，创建一个信号量对象：

System.Threading.Semaphore S = new System.Threading.Semaphore(3, 3);

然后，在每个线程中，您执行以下操作：

System.Threading.Semaphore S = new System.Threading.Semaphore(3, 3);

try
{
    // wait your turn (decrement)
    S.WaitOne();
    // do your thing
}

finally {
    // release so others can go (increment)
    S.Release();
}

每个线程都会在 S.WaitOne() 上阻塞，直到收到继续执行的信号。一旦 S 递减 3 次，所有线程将阻塞，直到其中一个线程递增计数器。

这个解决方案并不完美。

如果您想要更清洁、更高效的东西，我建议您使用 BlockingQueue 方法，其中您将要执行的工作排入全局 Blocking Queue 对象。

同时，您有三个线程（您创建的——不在线程池中），将工作从队列中弹出来执行。这并不难设置，而且非常快速和简单。

例子：

于 2009-01-14T21:06:46.610 回答
0

它和其他类一样是一个静态类，这意味着您对它所做的任何事情都会影响当前进程中的所有其他线程。它不会影响其他进程。

然而，我认为这是 .NET 中较大的设计缺陷之一。谁提出了使线程池静态化的绝妙主意？如您的示例所示，我们通常需要一个专用于我们的任务的线程池，而不会干扰系统中其他地方的不相关任务。

于 2009-01-14T21:02:31.737 回答