TPIE

11a2c2d
tpie::pipelining::parallel_bits::before_impl< dest_t > Class Template Reference

Concrete before class. More...

#include <tpie/pipelining/parallel/base.h>

Public Member Functions

template<typename Output >
 before_impl (state< item_type, Output > &st, size_t parId, dest_t dest)
 
virtual void push_all (array_view< item_type > items)
 Push all items from buffer and flush output buffer afterwards. More...
 

Detailed Description

template<typename dest_t>
class tpie::pipelining::parallel_bits::before_impl< dest_t >

Concrete before class.

Definition at line 39 of file base.h.

Member Function Documentation

◆ push_all()

template<typename dest_t >
virtual void tpie::pipelining::parallel_bits::before_impl< dest_t >::push_all ( array_view< item_type >  items)
inlinevirtual

Push all items from buffer and flush output buffer afterwards.

If pipeline is one-to-one, that is, one item output for each item input, then the flush at the end is not needed.

Definition at line 731 of file base.h.

731  {
732  for (size_t i = 0; i < items.size(); ++i) {
733  dest.push(items[i]);
734  }
735 
736  // virtual invocation
737  this->st.output(this->parId).flush_buffer();
738  }

References tpie::array_view_base< T >::size().


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