cpp-taskflow/examples/observer.cpp at master · OSHO-1989/cpp-taskflow · GitHub

43 lines (31 loc) · 1.09 KB

// 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 = taskflow.emplace([] () { std::cout << "1\n"; });

auto B = taskflow.emplace([] () { std::cout << "2\n"; });

auto C = taskflow.emplace([] () { std::cout << "3\n"; });

auto D = taskflow.emplace([] () { std::cout << "4\n"; });

auto E = taskflow.emplace([] () { std::cout << "5\n"; });

auto F = taskflow.emplace([] () { std::cout << "6\n"; });

auto G = taskflow.emplace([] () { std::cout << "7\n"; });

auto H = taskflow.emplace([] () { 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);

executor.remove_observer(observer);

return 0;

}

Expand file tree