20 #ifndef __TPIE_PIPELINING_PARALLEL_FACTORY_H__
21 #define __TPIE_PIPELINING_PARALLEL_FACTORY_H__
25 namespace pipelining {
27 namespace parallel_bits {
32 template <
typename fact_t>
37 template <
typename dest_t>
39 typedef typename dest_t::item_type T2;
43 typedef typename processor_t::item_type T1;
54 template <
typename dest_t>
55 typename constructed<dest_t>::type
56 construct(
const dest_t & dest)
const {
57 typedef constructed<dest_t> gen_t;
59 typedef typename gen_t::T1 input_type;
60 typedef typename gen_t::T2 output_type;
65 typedef typename gen_t::type producer_t;
67 typename state_t::ptr st(
new state_t(opts, fact));
83 #endif // __TPIE_PIPELINING_PARALLEL_FACTORY_H__
Factory instantiating a parallel multithreaded pipeline.
Accepts output items and sends them to the main thread.
Node running in main thread, accepting an output buffer from the managing producer and forwards them ...
User-supplied options to the parallelism framework.
State subclass containing the item type specific state, i.e.
Producer, running in main thread, managing the parallel execution.
Concrete consumer implementation.