GrPPI  0.2
Generic and Reusable Parallel Pattern Interface
Namespaces | Functions
omp/pipeline.h File Reference
#include "parallel_execution_omp.h"
#include <experimental/optional>
Include dependency graph for omp/pipeline.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 InQueue , typename Consumer >
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, Consumer &&consume_op)
 
template<typename Combiner , typename Identity , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, reduction_info< parallel_execution_omp, Combiner, Identity > &reduction_obj, MoreTransformers...more_transform_ops)
 
template<typename Combiner , typename Identity , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, reduction_info< parallel_execution_omp, Combiner, Identity > &&reduction_obj, MoreTransformers...more_transform_ops)
 
template<typename Combiner , typename Identity , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl_ordered (parallel_execution_omp &ex, InQueue &input_queue, reduction_info< parallel_execution_omp, Combiner, Identity > &&reduction_obj, MoreTransformers...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, filter_info< parallel_execution_omp, Transformer > &filter_obj, MoreTransformers &&...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl_ordered (parallel_execution_omp &ex, InQueue &input_queue, filter_info< parallel_execution_omp, Transformer > &&filter_obj, MoreTransformers &&...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl_unordered (parallel_execution_omp &ex, InQueue &input_queue, filter_info< parallel_execution_omp, Transformer > &&farm_obj, MoreTransformers &&...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, filter_info< parallel_execution_omp, Transformer > &&filter_obj, MoreTransformers &&...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, farm_info< parallel_execution_omp, Transformer > &farm_obj, MoreTransformers &&...more_transform_ops)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, farm_info< parallel_execution_omp, Transformer > &&farm_obj, MoreTransformers &&...sgs)
 
template<typename Transformer , typename InQueue , typename... MoreTransformers>
void grppi::pipeline_impl (parallel_execution_omp &ex, InQueue &input_queue, Transformer &&transform_op, MoreTransformers &&...more_transform_ops)
 
template<typename Generator , typename... Transformers, requires_no_arguments< Generator > = 0>
void grppi::pipeline (parallel_execution_omp &ex, Generator &&generate_op, Transformers &&...transform_ops)
 Invoke Pipeline pattern on a data stream with OpenMP parallel execution. More...