GrPPI  0.2
Generic and Reusable Parallel Pattern Interface
stream_reduce.h
Go to the documentation of this file.
1 
21 #ifndef GRPPI_STREAM_REDUCE_H
22 #define GRPPI_STREAM_REDUCE_H
23 
24 #include "seq/stream_reduce.h"
25 #include "native/stream_reduce.h"
26 #include "omp/stream_reduce.h"
27 #include "tbb/stream_reduce.h"
28 #include "poly/stream_reduce.h"
29 
30 #include "common/patterns.h"
31 
32 namespace grppi {
33 
54 template <typename Execution, typename Identity, typename Combiner>
55 auto stream_reduce(Execution & ex,
56  int window_size, int offset,
57  Identity identity,
58  Combiner && combine_op)
59 {
61  window_size, offset, identity,
62  std::forward<Combiner>(combine_op));
63 }
64 
70 }
71 
72 #endif
Definition: callable_traits.h:24
Definition: patterns.h:38
void stream_reduce(parallel_execution_native &ex, int window_size, int offset, Identity identity, Generator &&generate_op, Combiner &&combine_op, Consumer &&consume_op)
Invoke Stream reduction pattern on a stream with native parallel execution.
Definition: native/stream_reduce.h:56