examples/composition.cpp · uxsys/cpp-taskflow

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 37

uxsys/cpp-taskflow

forked from Gitee 极速下载/cpp-taskflow

代码 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

master

分支 (3)

标签 (15)

管理

master

dev

cpp14

v3.4.0

v3.3.0

v3.2.0

v3.1.0

v3.0.0

v2.7.0

v2.6.0

v2.5.0

2.5.0

v2.4.0

v2.3.1

v2.3.0

v2.2.0

v2.1.0

v2.0.0

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 3

标签 15

cpp-taskflow

examples

composition.cpp

composition.cpp 2.93 KB

// This example shows how to compose a taskflow
#include <taskflow/taskflow.hpp>

void composition_example_1() {

std::cout << "Composition example 1\n";

tf::Executor executor;

// f1 has three independent tasks
 tf::Taskflow f1("F1");
 auto f1A = f1.emplace([](){ std::cout << "F1 TaskA\n"; });
 auto f1B = f1.emplace([](){ std::cout << "F1 TaskB\n"; });
 auto f1C = f1.emplace([](){ std::cout << "F1 TaskC\n"; });
 f1A.name("f1A");
 f1B.name("f1B");
 f1C.name("f1C");
 f1A.precede(f1C);
 f1B.precede(f1C);

// f2A ---
 // |----> f2C ----> f1_module_task ----> f2D
 // f2B ---
 tf::Taskflow f2("F2");
 auto f2A = f2.emplace([](){ std::cout << " F2 TaskA\n"; });
 auto f2B = f2.emplace([](){ std::cout << " F2 TaskB\n"; });
 auto f2C = f2.emplace([](){ std::cout << " F2 TaskC\n"; });
 auto f2D = f2.emplace([](){ std::cout << " F2 TaskD\n"; });
 f2A.name("f2A");
 f2B.name("f2B");
 f2C.name("f2C");
 f2D.name("f2D");

f2A.precede(f2C);
 f2B.precede(f2C);

tf::Task f1_module_task = f2.composed_of(f1);
 f1_module_task.name("module");
 f2C.precede(f1_module_task);
 f1_module_task.precede(f2D);

f2.dump(std::cout);

executor.run_n(f2, 3).get();
}

void composition_example_2() {

std::cout << "Composition example 2\n";

tf::Executor executor;

// f1 has two independent tasks
 tf::Taskflow f1("F1");
 auto f1A = f1.emplace([&](){ std::cout << "F1 TaskA\n"; });
 auto f1B = f1.emplace([&](){ std::cout << "F1 TaskB\n"; });
 f1A.name("f1A");
 f1B.name("f1B");

// f2A ---
 // |----> f2C
 // f2B ---
 //
 // f1_module_task
 tf::Taskflow f2("F2");
 auto f2A = f2.emplace([&](){ std::cout << " F2 TaskA\n"; });
 auto f2B = f2.emplace([&](){ std::cout << " F2 TaskB\n"; });
 auto f2C = f2.emplace([&](){ std::cout << " F2 TaskC\n"; });
 f2A.name("f2A");
 f2B.name("f2B");
 f2C.name("f2C");

f2A.precede(f2C);
 f2B.precede(f2C);
 f2.composed_of(f1).name("module_of_f1");

// f3 has a module task (f2) and a regular task
 tf::Taskflow f3("F3");
 f3.composed_of(f2).name("module_of_f2");
 f3.emplace([](){ std::cout << " F3 TaskA\n"; }).name("f3A");

// f4: f3_module_task -> f2_module_task
 tf::Taskflow f4;
 f4.name("F4");
 auto f3_module_task = f4.composed_of(f3).name("module_of_f3");
 auto f2_module_task = f4.composed_of(f2).name("module_of_f2");
 f3_module_task.precede(f2_module_task);

f4.dump(std::cout);

executor.run_until(
 f4,
 [iter = 1] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "First run_until finished\n"; }
 ).get();

executor.run_until(
 f4,
 [iter = 2] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "Second run_until finished\n"; }
 );

executor.run_until(
 f4,
 [iter = 3] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "Third run_until finished\n"; }
 ).get();
}

int main(){
 composition_example_1();
 composition_example_2();
 return 0;
}

一键复制编辑原始数据按行查看历史

alexbriskin 提交于 2022年03月22日 04:24 +08:00 . Remove trailing whitespace (#386)

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117

// This example shows how to compose a taskflow
#include <taskflow/taskflow.hpp>

void composition_example_1() {

 std::cout << "Composition example 1\n";

 tf::Executor executor;

 // f1 has three independent tasks
 tf::Taskflow f1("F1");
 auto f1A = f1.emplace([](){ std::cout << "F1 TaskA\n"; });
 auto f1B = f1.emplace([](){ std::cout << "F1 TaskB\n"; });
 auto f1C = f1.emplace([](){ std::cout << "F1 TaskC\n"; });
 f1A.name("f1A");
 f1B.name("f1B");
 f1C.name("f1C");
 f1A.precede(f1C);
 f1B.precede(f1C);

 // f2A ---
 // |----> f2C ----> f1_module_task ----> f2D
 // f2B ---
 tf::Taskflow f2("F2");
 auto f2A = f2.emplace([](){ std::cout << " F2 TaskA\n"; });
 auto f2B = f2.emplace([](){ std::cout << " F2 TaskB\n"; });
 auto f2C = f2.emplace([](){ std::cout << " F2 TaskC\n"; });
 auto f2D = f2.emplace([](){ std::cout << " F2 TaskD\n"; });
 f2A.name("f2A");
 f2B.name("f2B");
 f2C.name("f2C");
 f2D.name("f2D");

 f2A.precede(f2C);
 f2B.precede(f2C);

 tf::Task f1_module_task = f2.composed_of(f1);
 f1_module_task.name("module");
 f2C.precede(f1_module_task);
 f1_module_task.precede(f2D);

 f2.dump(std::cout);

 executor.run_n(f2, 3).get();
}

void composition_example_2() {

 std::cout << "Composition example 2\n";

 tf::Executor executor;

 // f1 has two independent tasks
 tf::Taskflow f1("F1");
 auto f1A = f1.emplace([&](){ std::cout << "F1 TaskA\n"; });
 auto f1B = f1.emplace([&](){ std::cout << "F1 TaskB\n"; });
 f1A.name("f1A");
 f1B.name("f1B");

 // f2A ---
 // |----> f2C
 // f2B ---
 //
 // f1_module_task
 tf::Taskflow f2("F2");
 auto f2A = f2.emplace([&](){ std::cout << " F2 TaskA\n"; });
 auto f2B = f2.emplace([&](){ std::cout << " F2 TaskB\n"; });
 auto f2C = f2.emplace([&](){ std::cout << " F2 TaskC\n"; });
 f2A.name("f2A");
 f2B.name("f2B");
 f2C.name("f2C");

 f2A.precede(f2C);
 f2B.precede(f2C);
 f2.composed_of(f1).name("module_of_f1");

 // f3 has a module task (f2) and a regular task
 tf::Taskflow f3("F3");
 f3.composed_of(f2).name("module_of_f2");
 f3.emplace([](){ std::cout << " F3 TaskA\n"; }).name("f3A");

 // f4: f3_module_task -> f2_module_task
 tf::Taskflow f4;
 f4.name("F4");
 auto f3_module_task = f4.composed_of(f3).name("module_of_f3");
 auto f2_module_task = f4.composed_of(f2).name("module_of_f2");
 f3_module_task.precede(f2_module_task);

 f4.dump(std::cout);

 executor.run_until(
 f4,
 [iter = 1] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "First run_until finished\n"; }
 ).get();

 executor.run_until(
 f4,
 [iter = 2] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "Second run_until finished\n"; }
 );

 executor.run_until(
 f4,
 [iter = 3] () mutable { std::cout << '\n'; return iter-- == 0; },
 [](){ std::cout << "Third run_until finished\n"; }
 ).get();
}

int main(){
 composition_example_1();
 composition_example_2();
 return 0;
}