GrPPI
0.3.1
Generic and Reusable Parallel Pattern Interface
|
Classes | |
struct | ff_arena_t |
Tag type for fastflow allocation. This empty type is used to select the overloaded placement new and delete operators that invoke the fastflow allocation routines. More... | |
class | filter_collector |
Colletor node for a filter. More... | |
class | filter_emitter |
Emitter for a filter stage. More... | |
class | filter_worker |
Worker that passes a value to next stage if the predicate is satisfied or the filtered_value constant otherwise. More... | |
class | iteration_worker |
class | node_impl |
Fastflow node for a pipeline transformation stage. More... | |
class | node_impl< Input, void, Consumer > |
Fastflow node for a pipeline consumer stage. More... | |
class | node_impl< void, Output, Generator > |
Fastflow node for a pipeline generation stage. More... | |
class | ordered_stream_filter |
class | ordered_stream_reduce |
Ordered stream reduce for FastFlow. More... | |
class | reduce_collector |
Reduce collector. More... | |
class | reduce_emitter |
Reduce emitter. More... | |
class | reduce_worker |
Reduce worker. More... | |
class | unordered_stream_filter |
class | unordered_stream_reduce |
Functions | |
template<typename T > | |
constexpr T * | filtered_value () |
Get a pointer representation of the filter constant to be used as special value when a value is filtered out. More... | |
Variables | |
constexpr ff_arena_t | ff_arena |
Fastflow arena object. This object will be passed to placement new/delete to use FastFlow allocation strategy. More... | |
workers_ {} | |
p_emitter_ {std::make_unique<emitter_type>(reducer.window_size(), reducer.offset())} | |
constexpr T* grppi::detail_ff::filtered_value | ( | ) |
Get a pointer representation of the filter constant to be used as special value when a value is filtered out.
constexpr ff_arena_t grppi::detail_ff::ff_arena |
Fastflow arena object. This object will be passed to placement new/delete to use FastFlow allocation strategy.
grppi::detail_ff::p_emitter_ {std::make_unique<emitter_type>(reducer.window_size(), reducer.offset())} |
grppi::detail_ff::workers_ {} |