GrPPI  0.2
Generic and Reusable Parallel Pattern Interface
Namespaces | Functions
native/stream_iteration.h File Reference
#include "parallel_execution_native.h"
#include <thread>
#include <utility>
#include <memory>
Include dependency graph for native/stream_iteration.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Namespaces

 grppi
 

Functions

template<typename Generator , typename Predicate , typename Consumer , typename... MoreTransformers>
void grppi::repeat_until (parallel_execution_native &ex, Generator &&generate_op, pipeline_info< parallel_execution_native, MoreTransformers... > &&pipe, Predicate predicate_op, Consumer consume_op)
 Invoke Stream iteration pattern on a data stream with native parallel execution with a generator, a predicate, a consumer and a pipeline as a transformer. More...
 
template<typename Generator , typename Transformer , typename Predicate , typename Consumer >
void grppi::repeat_until (parallel_execution_native &ex, Generator generate_op, farm_info< parallel_execution_native, Transformer > &&farm, Predicate predicate_op, Consumer consume_op)
 Invoke Stream iteration pattern on a data stream with native parallel execution with a generator, a predicate, a consumer and a farm as a transformer. More...
 
template<typename Generator , typename Transformer , typename Predicate , typename Consumer >
void grppi::repeat_until (parallel_execution_native &ex, Generator generate_op, Transformer transform_op, Predicate predicate_op, Consumer consume_op)
 Invoke Stream iteration pattern on a data stream with native parallel execution with a generator, a predicate, a transformer and a consumer. More...