in reply to Re: any module with streaming pipe implementation for use with threads
in thread any module with streaming pipe implementation for use with threads

Thanks nick, for the suggestions. I started to implement my class the way you have described :), but it fell short when multiple get/put calls are made at the same time. Also I need the calls to be blocking/nb.

I tested the code over 5M iterations and all the data is popd out, I believe the threads make a copy of pipe1, but the store_array & lock vars are part of a shared location.

  • Comment on Re^2: any module with streaming pipe implementation for use with threads