.net 4.0 上的 BlockingCollection 非常独特的例外

Question

我正在使用 BlockingCollection 作为生产者消费者模式，但我遇到了一个例外，我想为此写一个专利 - 谷歌中只有两个结果！ 期望是“CompleteAdding 不能与集合中的添加同时使用”，当我在 BlockingCollection 上进行 TryAdd 时，就会发生这种情况，如下所示：

 public void EnqueueTask(T item)
    {
        if (!_cancellationTokenSource.IsCancellationRequested)
        {
            _workerQueue.Add(item);
        }
    }

在处理时调用 CompleteAdding消费者-生产者包装类：

  public void Dispose()
    {
        if (!_IsActive)
            return;
        _IsActive = false;
        _cancellationTokenSource.Cancel();
        _workerQueue.CompleteAdding();
        // Wait for the consumer's thread to finish.
        for (int i = 0; i < _workers.Length; ++i)
        {
            Task t1 = Task.Factory.StartNew(() =>
            {
                try
                {
                    if (!_workers[i].Join(4000))
                        LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose");
                }
                catch (Exception ex)
                {
                    OnLogged(ex.Message + ex.StackTrace);
                }
            });

        }


        // Release any OS resources.
    }

微软的任何人有一个想法吗？我应该在取消之后和调用 CompleteAdding 之前睡觉吗？

Answer 1

看一下这段代码：

    for (int i = 0; i < _workers.Length; ++i)
    {
        Task t1 = Task.Factory.StartNew(() =>
        {
            try
            {
                if (!_workers[i].Join(4000))   << == Here
                    LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose");
            }

在_workers[i].Join(4000)中，i的值并不是你想象的那样。重试：

   for (int i = 0; i < _workers.Length; ++i)
    {
        int j = i;  // copy
        Task t1 = Task.Factory.StartNew(() =>
        {
            try
            {
                if (!_workers[j].Join(4000))  // j
                    LogWriter.Trace("Failed to join thread", "ThreadFailureOnDispose");
            }

在您的版本中，捕获变量“i”并且所有任务都使用相同的变量。除了前几个之外，所有其他都会看到 i == _workers.Length 因为它们是在 for 循环完成后执行的。

这是一个经典的 lambda + 捕获的 var 问题。