迭代 ConcurrentQueue

Question

这是迭代 ConcurrentQueue< 的安全方法吗/a>?

while (cq.GetEnumerator().MoveNext())
{
    IIndexTask task;
    if (cq.TryDequeue(out task))
        task.Execute(service);
}

Answer 1

只需这样做...

IIndexTask task;
while (cq.TryDequeue(out task))
{
    task.Execute(service);
}