正确使用 ConcurrentBag

Question

编辑：谢谢，你让我意识到下面的代码不像我想象的那样工作，因为不知何故我认为 cbag 像一个哈希集一样工作。对不起，你让我有些头疼:)

以下函数是唯一可以改变_currentSetOfStepsProcessing 的函数。这个函数可以被不同的线程调用。我不确定我是否正确理解了 ConcurrentBag 的使用，所以请让我知道您认为这是否可行。 _stepsToDo 数据结构一旦进程开始就永远不会被修改。

void OnStepDone(InitialiseNewUserBase obj)
    {
        var stepToDo = _stepsToDo[_currentSetOfStepsProcessing];

        stepToDo.TryTake(out obj);

        if (stepToDo.Count == 0) //can I assume it will enter here once per ConcurrentBag?
        {
            if (_currentSetOfStepsProcessing < _stepsToDo.Count - 1)
            {
                _currentSetOfStepsProcessing++;
            }
        }
    }

    List<ConcurrentBag<InitialiseNewUserBase>>      _stepsToDo = new List<ConcurrentBag<InitialiseNewUserBase>>();
    Action                                          _onFinish;
    int                                             _currentSetOfStepsProcessing;

Answer 1

1. stepToDo.TryTake(out obj); 可能会失败，你别管它。
2. 为什么out-引用方法参数？这只是覆盖了参数。如果你把它扔掉，为什么还要争论呢？更有可能的是，这是某种误解。
3. can I assume it will enter here once per ConcurrentBag 因为对包的访问显然是并发的，多个访问线程可能会看到 0。所以是的，您需要更好地处理这种情况。

也许，您不应该把事情弄得那么困难，而是将lock 与非并发数据结构结合使用。只有在似乎不太可能的包操作频率很高的情况下，这才是一个好主意。

这个呢：

foreach (/*processing step*/) {
 Parallel.ForEach(/*item in the step*/, x => { ... });
}

简单得多。