Accepts input items from the main thread and sends them down the pipeline. More...
#include <tpie/pipelining/parallel/base.h>
Public Types | |
| typedef T | item_type |
Public Member Functions | |
| void | begin () override |
| void | end () override |
Protected Member Functions | |
| virtual void | push_all (array_view< T > items)=0 |
| Overridden in subclass to push a buffer of items. More... | |
| template<typename Output > | |
| before (state< T, Output > &st, size_t parId) | |
| before (const before &other) | |
Protected Attributes | |
| state_base & | st |
| size_t | parId |
| std::unique_ptr< parallel_input_buffer< T > > | m_buffer |
| array< parallel_input_buffer< T > * > & | m_inputBuffers |
| std::thread | m_worker |
Accepts input items from the main thread and sends them down the pipeline.
This class contains the bulk of the code that is run in each worker thread.
|
protectedpure virtual |
Overridden in subclass to push a buffer of items.