当调用BlockingCollection.Take()时,集合的IsCompleted状态可以在IsCompleted的检查和对Take()的调用之间进行更改.
显示一个例子的MSDN Documentation只是捕获无效的操作异常,但是似乎必须有一个正确的方法来执行这样一个调用,而不捕获异常(因为这会引起一个体面的开销,并且看起来不太干净) .什么是正确的方法调用.Take()和避免无效的操作异常？
我的具体问题的简化版本：
If (!blockingCollection.IsCompleted)
{
//do some stuff
value = blockingCollection.Take(); //Throws Exception,IsCompleted = True;
}
有一个TryTake方法可用,但我的印象是,这样可以传递一个超时和取消令牌,而不是在它被检查的时间和当Take()被调用时,IsCompleted变为true .
解决方法
您可以使用
TryTake overload with no timeout/cancelation.如果BlockingCollection为空或已经标记完成,它将返回false,并处理正确的同步问题.
