test_tbb.cxx File Reference

#include <tbb/flow_graph.h>
#include <iostream>
#include <tuple>
#include <chrono>
#include <thread>

Go to the source code of this file.

Classes
struct	number_source< DataType >
struct	I2Fcaster

Typedefs
typedef dfp::multifunction_node< int, tbb::flow::tuple< float > >	int2float_node

Functions
void	msleep (int msec)
int	main ()

Typedef Documentation

typedef dfp::multifunction_node<int, tbb::flow::tuple<float> > int2float_node

Definition at line 28 of file test_tbb.cxx.

Function Documentation

int main

(

void

)

Definition at line 50 of file test_tbb.cxx.

           {
    dfp::graph g;
    std::vector<int> numbers{5,4,3,2,1,0};
    dfp::source_node<int> number_source_node(g, number_source<int>(numbers), false);
    dfp::function_node<int, int> int_chirp_node(g, dfp::unlimited, [](const int &v) {
            cerr << "i value: " << v << endl;
            msleep(v*100);
            cerr << "...woke, returning i=" << v << endl;
            return v;
        });
    dfp::function_node<float,float> float_chirp_node(g, dfp::unlimited, [](const float &v) {
            cerr << "f value: " << v << endl;
            msleep(v*100);
            cerr << "...woke, returning f=" << v << endl;
            return v;
        });
    int2float_node i2fcaster_node(g, dfp::unlimited, I2Fcaster());
    
    cerr << "make edges" << endl;
    make_edge(number_source_node, int_chirp_node);
    make_edge(int_chirp_node, i2fcaster_node);
    make_edge(dfp::output_port<0>(i2fcaster_node), float_chirp_node);

    cerr << "Activate source" << endl;
    number_source_node.activate();
    cerr << "Waiting for graph" << endl;
    g.wait_for_all();
    return 0;
}

void msleep

(

int

msec

)

Definition at line 45 of file test_tbb.cxx.

{
    std::this_thread::sleep_for(std::chrono::milliseconds(msec));
}