ManualResetEvent - WaitOne()在某些时候似乎没有释放线程

我有一个多线程表单应用程序，这就是所讨论的部分是如何设计的:

线程2 (BatchPreviewAssistant类)正在等待主接口线程传递图像加载任务。接收到任务后，BatchPreviewAssistant将任务分配给N=5个等待的PrimaryLoader线程并启用它们。PrimaryLoaders作为无限循环运行，使用2个手动重置事件启动/停止:_startEvent和_endEvent。此外，还有一个N个手动重置事件数组_parentSyncEvent来表示从PrimaryLoaders到BatchPreviewAssistant的处理结束。

所以通常每个PrimaryLoader都在_starteevent . waitone()等待。一旦BatchPreviewAssistant需要激活它们并运行RunPrimaryLoaders()，它首先重置_endEvent和_parentSyncEvents，然后设置_startEvent。现在它在WaitHandle处阻塞。WaitAll (_parentSyncEvents_starteevent . set()导致所有PrimaryLoader继续。一旦每个PrimaryLoader完成，它将在_parentSyncEvent中设置自己的事件，直到所有5个事件都设置完成。此时，所有的PrimaryLoaders都到达_endEvent.WaitOne()并等待。现在_parentSyncEvents全部设置，使BatchPreviewAssistant继续。BatchPreviewAssistant重置_startEvent，然后设置_endEvent，释放PrimaryLoaders，它们回到循环的开始。

BatchPreviewAssistant:

    private void RunPrimaryLoaders()
    {
        BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Debug1, "RunPrimaryLoaders()");
        ResetEvents(_parentSyncEvents);
        _endEvent.Reset();
        _startEvent.Set();
        // Primary Loader loops restart
        BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Debug2, "WaitHandle.WaitAll(_parentSyncEvent");
        if (!WaitHandle.WaitAll(_parentSyncEvents, 20 * 1000))
        {
            throw new TimeoutException("WaitAll(_parentSyncEvent) in ProcessCurrentCommand");
            // TODO: Terminate?
        }
        BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Message3, "Primary loading is complete");
        _startEvent.Reset();
        _endEvent.Set();
        bool isEndEventSet = _endEvent.WaitOne(0);
        BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Debug2, "isEndEventSet?" + isEndEventSet.ToString());
    }

知荷载:

    public void StartProc(object arg)
    {
        while (true)
        {
            BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Debug2, "Primary Loader: _startEvent.WaitOne()");
            _startEvent.WaitOne();
            try
            {
                BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Message4, "Primary Loader is processing entry:" + processingEntry.DisplayPosition.ToString());
            }
            catch (Exception ex)
            {
                BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Error, "Exception in PrimaryImageLoader.StartProc:" + ex.ToString());
            }
            _parentSyncEvent.Set();
            BatchPreviewThreadsLogger.WriteLog(Common.LogLevel.Debug2, "Primary Loader: _endEvent.WaitOne()");
            _endEvent.WaitOne();
        }
    }

这段代码运行得很好，做了数百个这样的循环，但我偶尔会遇到一个问题，特别是在压力测试期间。当BatchPreviewAssistant设置_endEvent.Set()时，没有一个PrimaryLoaders在_endEvent.WaitOne()释放;你可以看到我在BatchPreviewAssistant中检查，看到事件确实设置了，但是PrimaryLoaders没有被释放。

[10/27/2011;21:24:42.796;INFO ] [42-781:16]Primary Loader: _endEvent.WaitOne()
[10/27/2011;21:24:42.796;INFO ] [42-781:18]Primary Loader: _endEvent.WaitOne()
[10/27/2011;21:24:42.796;INFO ] [42-781:19]Primary Loader: _endEvent.WaitOne()
[10/27/2011;21:24:42.843;INFO ] [42-843:15]Primary Loader: _endEvent.WaitOne()
[10/27/2011;21:24:42.937;INFO ] [42-937:17]Primary Loader: _endEvent.WaitOne()
[10/27/2011;21:24:42.937;INFO ] [42-937:14]Primary loading is complete
[10/27/2011;21:24:42.937;INFO ] [42-937:14]isEndEventSet?True

这样的设计是否有明显的问题可能导致问题?我可以看到一些方法来尝试周围的工作，但它会很高兴看到什么是错误的这种方法。

以防万一，我还提供了关于初始化和启动PrimaryLoaders的方式的信息。

private PrimaryImageLoader[] _primaryImageLoaders;
_primaryImageLoaders = new PrimaryImageLoader[N]
for (int i = 0; i < _primaryImageLoaderThreads.Length; i++)
{
  _parentSyncEvents[i] = new AutoResetEvent(false);
  _primaryImageLoaders[i] = new PrimaryImageLoader(i, _parentSyncEvents[i], 
      _startEvent, _endEvent,
      _pictureBoxes, _asyncOperation,
      LargeImagesBufferCount);
  _primaryImageLoaderThreads[i] = new Thread(new ParameterizedThreadStart(_primaryImageLoaders[i].StartProc));
  _primaryImageLoaderThreads[i].Start();
}

请注意，为了简化示例

，已经删除了一些不相关的代码。

补充道:我同意样品太忙了，很难跟进。简而言之就是:

Thread 2:
private void RunPrimaryLoaders()
{
  _endEvent.Reset();
  _startEvent.Set();
  _startEvent.Reset();
  _endEvent.Set();
  bool isEndEventSet = _endEvent.WaitOne(0);
}
Threads 3-7:
public void StartProc(object arg)
{
  while (true)
  {
    _startEvent.WaitOne();
    _endEvent.WaitOne();     // This is where it can't release occasionally although Thread 2 checks and logs that the event is set
  }
}

class Producer
{
    private readonly BlockingQueue<Task> _queue;
    public Producer(BlockingQueue<Task> queue)
    {
        _queue = queue;
    }
    public LoadImages(List<Task> imageLoadTasks)
    {
        foreach(Task t in imageLoadTasks)
        {
            _queue.Enqueue(task);
        }
    }
}
class Consumer
{
    private volatile bool _running;
    private readonly BlockingQueue<Task> _queue;
    public Consumer(BlockingQueue<Task> queue)
    {
        _queue = queue;
        _running = false;
    }
    public Consume()
    {
        _running = true;
        while(_running)
        {
            try
            {
                // Blocks on dequeue until there is a task in queue
                Task t = _queue.Dequeue();
                // Execute the task after it has been dequeued
                t.Execute();
            }
            catch(ThreadInterruptedException)
            {
                // The exception will take you out of a blocking
                // state so you can check the running flag and decide
                // if you need to exit the loop or if you shouldn't.
            }
        }
    }
}