信号量 WaitOne 无法正常运行

Question

我有一个信号量，假设限制为 3，但是，它只是不停地调用它想要的数量。我假设这是因为我使用（1000）。但是，当我只尝试 () 时，它永远不会通过 WaitOne 我不确定在这里做什么。

private static Semaphore _pool;
_pool = new Semaphore(0, 3);
var options = new ParallelOptions();
options.MaxDegreeOfParallelism = 1;
Parallel.ForEach(urlTable.AsEnumerable(),options, drow =>
{
    using (var WCC = new MasterCrawlerClass())
    {
                ActiveThreads++;
                _pool.WaitOne(1000);
                Console.WriteLine("Active Thread #: " + ActiveThreads);
                WCC.MasterCrawlBegin(drow);
                Console.WriteLine("Done Crawling a datarow");
                ActiveThreads--;
                _pool.Release();

    }
});

Answer 1

您对信号量的构造有误。应该是_pool = new Semaphore(3, 3); 这样做还可以消除将超时参数传递给WaitOne() 的需要。

第一个参数是在阻塞之前可能被授予的初始请求数，因此传递 0 意味着任何后续对 WaitOne() 的调用将立即阻塞。

Answer 2

这里有一些问题。

• 我怀疑首先在这种情况下没有理由限制并发。
• 您在Semaphore 构造函数中将initialCount 设置为0。 initialCount 是现在可以授予的请求数。
• 您正在使用接受超时参数的WaitOne 的重载。当超时到期时，WaitOne 将返回，无论是否从信号量中获取计数。
• 您正在递增ActiveThreads在从信号量中进行计数。这意味着ActiveThreads 更接近于ForEach 操作的同时工作线程数。它不会告诉你有多少线程正在执行MasterCrawlBegin。
• ActiveThreads 上的 ++ 操作不是线程安全的。
• 您将MaxDegreesOfParallelism 设置为一个几乎可以消除任何类型的并发处理的值。

更改您的代码，使其看起来像这样。

int ActiveThreads = 0;
int ActiveCrawls = 0;
var semaphore = new SemaphoreSlim(3, 3); 
Parallel.ForEach(urlTable.AsEnumerable(), drow => 
  { 
    int x = Interlocked.Increment(ref ActiveThreads);
    Console.WriteLine("Active Thread #: " + x); 
    semaphore.Wait();
    int y = Interlocked.Increment(ref ActiveCrawls);
    Console.WriteLine("Active Crawl #: " + y); 
    try
    {
      using (var WCC = new MasterCrawlerClass()) 
      { 
        WCC.MasterCrawlBegin(drow);
      }
    }
    finally
    {
      Interlocked.Decrement(ref ActiveCrawls);
      semaphore.Release();
      Interlocked.Decrement(ref ActiveThreads);
      Console.WriteLine("Done Crawling a datarow"); 
    }
  } 
}); 

当然，您可以只设置MaxDegreesOfParallelism = 3 而不必担心所有信号量的东西。