I'm starting to work with TPL right now. I have seen a simple version of the producer/consumer model utilizing TPL in this video.
Here is the problem:
The following code:
BlockingCollection<Double> bc = new BlockingCollection<Double>(100);
IEnumerable<Double> d = bc.GetConsumingEnumerable();
returns an IEnumerable<Double>
which can be iterated (and automatically consumed) using a foreach:
foreach (var item in d)
{
// do anything with item
// in the end of this foreach,
// will there be any items left in d or bc? Why?
}
My questions are:
IEnumerator<Double> dEnum = d.GetEnumerator()
from d
(to iterate over d
with a while
loop, for instance) would the d.MoveNext()
consume the list as well? (My answer: I don't think so, because the the dEnum
is not linked with d
, if you know what I mean. So it would consume dEnum
, but not d
, nor even bc
)bc
(or d
) in a way other than the foreach
loop, consuming the items? (the while
cycles much faster than the foreach
loop and I'm worried with performance issues for scientific computation problems)BlockingCollection<T>
type?E.g., code:
IEnumerator<Double> dEnum = d.GetEnumerator();
while (dEnum.MoveNext())
{
// do the same with dEnum.Current as
// I would with item in the foreach above...
}
Thank you all in advance!
If I get the
IEnumerator<Double> dEnum = d.GetEnumerator()
from d (to iterate over d with a while loop, for instance) would the d.MoveNext() consume the list as well?
Absolutely. That's all that the foreach
loop will do anyway.
May I loop through bc (or d) in a way other than the foreach loop, consuming the items? (the while cycles much faster than the foreach loop and I'm worried with performance issues for scientific computation problems)
If your while
loop is faster, that suggests you're doing something wrong. They should be exactly the same - except the foreach
loop will dispose of the iterator too, which you should do...
If you can post a short but complete program demonstrating this discrepancy, we can look at it in more detail.
An alternative is to use Take
(and similar methods).
What does exactly consume mean in the BlockingCollection type?
"Remove the next item from the collection" effectively.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With