I'm trying to getting out of OutOfMemory Exception, so I noticed about 1.5
Million rows are being cached in the CachingEnumerable object ... I wonder
why this doesn't stream ... why its cached. So I changed the following
lines:
protected IEnumerable<Row> GetRightEnumerable()
{
//IEnumerable<Row> rightEnumerable = new CachingEnumerable<Row>(
// new EventRaisingEnumerator(right, right.Execute(null))
// );
IEnumerable<Row> rightEnumerable = new
EventRaisingEnumerator(right, right.Execute(null));
and it works perfectly with much less memory ... I only had to increase the
input operation timeout value
All is good except with MultiThreadedBranchingOperation ... where after some
processing it get stuck on:
lock (sync)
while (input.ConsumersLeft > 0)
Monitor.Wait(sync); // <--------------------------- here
Questions:
why you cache to join?
why it stucks there ?
Thanks
--
You received this message because you are subscribed to the Google Groups
"Rhino Tools Dev" group.
To view this discussion on the web visit
https://groups.google.com/d/msg/rhino-tools-dev/-/rOzjgybGSYkJ.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to
[email protected].
For more options, visit this group at
http://groups.google.com/group/rhino-tools-dev?hl=en.
