❔ How to pause BlockingCollection consumption?

I'm currently enumerating through a

BlockingCollection

BlockingCollection

(with an underlying

ConcurrentQueue

ConcurrentQueue

backing class) using

GetConsumingEnumerable()

GetConsumingEnumerable()

. But I have to pause execution based on some logic, leaving items on the queue, until some other business logic resumes execution. Anyone know the best practice for that? Do I have to bypass

GetConsumingEnumerable()

GetConsumingEnumerable()

and instead write something like below, but adding pause logic?

while (!IsCompleted)
{
  if (TryTake(out var item, Timeout.Infinite))
    yield return item;
}

while (!IsCompleted)
{
  if (TryTake(out var item, Timeout.Infinite))
    yield return item;
}

C#•4y ago•

2 replies

Tandy

❔ How to pause BlockingCollection consumption?

I'm currently enumerating through a

BlockingCollection

BlockingCollection

(with an underlying

ConcurrentQueue

ConcurrentQueue

backing class) using

GetConsumingEnumerable()

GetConsumingEnumerable()

. But I have to pause execution based on some logic, leaving items on the queue, until some other business logic resumes execution. Anyone know the best practice for that? Do I have to bypass

GetConsumingEnumerable()

GetConsumingEnumerable()

and instead write something like below, but adding pause logic?

while (!IsCompleted)
{
  if (TryTake(out var item, Timeout.Infinite))
    yield return item;
}

while (!IsCompleted)
{
  if (TryTake(out var item, Timeout.Infinite))
    yield return item;
}

❔ How to pause BlockingCollection consumption?

Similar Threads

❔ How to pause BlockingCollection consumption?

Similar Threads

Similar Threads

Similar Threads