cpp-taskflow/examples/runtime_async.cpp at master · EMinsight/cpp-taskflow · GitHub

31 lines (24 loc) · 811 Bytes

// The program demonstrates how to create asynchronous task

// from a running subflow.

#include <taskflow/taskflow.hpp>

int main() {

tf::Taskflow taskflow("Subflow Async");

tf::Executor executor;

std::atomic<int> counter{0};

taskflow.emplace([&](tf::Runtime& rt){

for(int i=0; i<10; i++) {

// Here, we use "silent_async" instead of "async" because we do

// not care the return value. The method "silent_async" gives us

// less overhead compared to "async".

// The 10 asynchronous tasks run concurrently.

rt.silent_async([&](){

std::cout << "async task from the subflow\n";

counter.fetch_add(1, std::memory_order_relaxed);

});

}

rt.corun();

std::cout << counter << " = 10\n";

});

executor.run(taskflow).wait();

return 0;

}

Expand file tree