cpp-taskflow/example/observer.cpp at master · femperor/cpp-taskflow · GitHub

43 lines (32 loc) · 935 Bytes

// Demonstrates the use of observer to monitor worker activities

#include <taskflow/taskflow.hpp>

int main(){

tf::Executor executor;

// Create a taskflow of eight tasks

tf::Taskflow taskflow;

auto [A, B, C, D, E, F, G, H] = taskflow.emplace(

[] () { std::cout << "1\n"; },

[] () { std::cout << "2\n"; },

[] () { std::cout << "3\n"; },

[] () { std::cout << "4\n"; },

[] () { std::cout << "5\n"; },

[] () { std::cout << "6\n"; },

[] () { std::cout << "7\n"; },

[] () { std::cout << "8\n"; }

);

A.name("A");

B.name("B");

C.name("C");

D.name("D");

E.name("E");

F.name("F");

G.name("G");

H.name("H");

// create a default observer

auto observer = executor.make_observer<tf::ExecutorObserver>();

// run the taskflow

executor.run(taskflow).get();

// dump the execution timeline to json (view at chrome://tracing)

observer->dump(std::cout);

return 0;

}

Expand file tree