test_tbb_join.cxx File Reference

#include <tbb/flow_graph.h>
#include <iostream>

Go to the source code of this file.

Classes
struct	CountDown
struct	MyJoin
struct	Chirp
struct	TupleHelper< TupleType, N >
struct	TupleHelper< TupleType, 0 >
struct	Adder

Typedefs
typedef tbb::flow::receiver< int >	int_receiver

Functions
int	main ()

Typedef Documentation

typedef tbb::flow::receiver<int> int_receiver

Definition at line 45 of file test_tbb_join.cxx.

Function Documentation

int main

(

void

)

Definition at line 103 of file test_tbb_join.cxx.

{
    tbb::flow::graph graph;
    
    typedef tbb::flow::source_node<int> int_source;
    vector<int_source> countdowns;

    int n = 3;                  // explicitly nonconst
    for (int i=0; i<n; ++i) {
        countdowns.push_back(int_source(graph,CountDown(i),false)); 
    }

    // join
    typedef std::tuple<int,int,int> IntTriple;
    TupleHelper<IntTriple,3> th;

    typedef tbb::flow::join_node< IntTriple > JoinInt3;
    JoinInt3 jn(graph);
    vector<int_receiver*> jrec = th.input_ports(jn);

    tbb::flow::function_node< std::tuple<int,int,int>, vector<int> > bo(graph, 0, th);
    tbb::flow::function_node< vector<int>, int > fn(graph, 0, Adder());

    for (int i=0; i<n; ++i) {
        make_edge(countdowns[i],*jrec[i]);
    }
    make_edge(jn, bo);
    make_edge(bo, fn);
    for (int i=0; i<n; ++i) {
        countdowns[i].activate();
    }

    graph.wait_for_all();
}