TPIE

11a2c2d
tpie::pipelining::parallel_bits::before< T > Class Template Referenceabstract

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_basest
 
size_t parId
 
std::unique_ptr< parallel_input_buffer< T > > m_buffer
 
array< parallel_input_buffer< T > * > & m_inputBuffers
 
std::thread m_worker
 

Detailed Description

template<typename T>
class tpie::pipelining::parallel_bits::before< T >

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.

Definition at line 37 of file base.h.

Member Function Documentation

◆ push_all()

template<typename T >
virtual void tpie::pipelining::parallel_bits::before< T >::push_all ( array_view< T >  items)
protectedpure virtual

Overridden in subclass to push a buffer of items.


The documentation for this class was generated from the following file: