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.
|
|---|