2 Jul
2014
2 Jul
'14
1:20 p.m.
On 2 Jul 2014 at 7:51, Oliver Kowalke wrote:
You could use boost.fiber (std::thread-like API) to run multiple tasks (transformations) inside a single thread concurrently. At least with fibers you can use a fixed size threadpool without overloading/blocking the pool with too many tasks.
How would that help him with the blocking from the i/o? The coroutines need to fire every time a chunk comes in from the i/o source, but what is a chunk? Each processor will define a chunk differently, and that means each section of the pipeline needs to carry state. Niall -- ned Productions Limited Consulting http://www.nedproductions.biz/ http://ie.linkedin.com/in/nialldouglas/