FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
cpp-taskflow/example/run_variants.cpp at master · superwind/cpp-taskflow · GitHub
superwind
/
cpp-taskflow
Public
forked from
taskflow/taskflow
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Pull requests
0
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
cpp-taskflow
/
example
/
run_variants.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
66 lines (50 loc) · 1.98 KB
Breadcrumbs
cpp-taskflow
/
example
/
run_variants.cpp
Copy path
File metadata and controls
66 lines (50 loc) · 1.98 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
//
This example demonstrates how to use different methods to
//
run a taskflow object.
#
include
<
taskflow/taskflow.hpp
>
int
main
(){
//
create an executor and a taskflow
tf::Executor executor;
tf::Taskflow
taskflow
(
"
Demo
"
);
auto
A = taskflow.
emplace
([&](){ std::cout <<
"
TaskA
\n
"
; }).
name
(
"
A
"
);
auto
B = taskflow.
emplace
([&](
auto
& subflow){
std::cout <<
"
TaskB
\n
"
;
auto
B1
= subflow.
emplace
([&](){ std::cout <<
"
TaskB1
\n
"
; }).
name
(
"
B1
"
);
auto
B2
= subflow.
emplace
([&](){ std::cout <<
"
TaskB2
\n
"
; }).
name
(
"
B2
"
);
auto
B3
= subflow.
emplace
([&](){ std::cout <<
"
TaskB3
\n
"
; }).
name
(
"
B3
"
);
B1
.
precede
(
B3
);
B2
.
precede
(
B3
);
}).
name
(
"
B
"
);
auto
C = taskflow.
emplace
([&](){ std::cout <<
"
TaskC
\n
"
; }).
name
(
"
C
"
);
auto
D = taskflow.
emplace
([&](){ std::cout <<
"
TaskD
\n
"
; }).
name
(
"
D
"
);
A.
precede
(B, C);
B.
precede
(D);
C.
precede
(D);
std::cout <<
"
Run the framework once without callback
\n
"
;
std::cout <<
"
Dump the framework before execution:
\n
"
;
taskflow.
dump
(std::cout);
std::cout << std::endl;
executor.
run
(taskflow).
get
();
std::cout << std::endl;
std::cout <<
"
Dump after execution:
\n
"
;
taskflow.
dump
(std::cout);
std::cout << std::endl;
std::cout <<
"
Use wait_for_all to wait for the run to finish
\n
"
;
executor.
run
(taskflow);
executor.
wait_for_all
();
std::cout << std::endl;
std::cout <<
"
Execute the framework two times without a callback
\n
"
;
executor.
run_n
(taskflow,
2
).
get
();
std::cout <<
"
Dump after two executions:
\n
"
;
taskflow.
dump
(std::cout);
std::cout << std::endl;
std::cout <<
"
Execute the framework four times with a callback
\n
"
;
executor.
run_n
(taskflow,
4
, [] () { std::cout <<
"
The framework finishes
\n
"
; }).
get
();
std::cout << std::endl;
std::cout <<
"
Run the framework until a counter (init value=3) becomes zero
\n
"
;
executor.
run_until
(taskflow, [counter=
3
]()
mutable
{
std::cout <<
"
Counter =
"
<< counter << std::endl;
return
counter -- ==
0
;
}).
get
();
taskflow.
dump
(std::cout);
return
0
;
}
Back
|
FazBrowse Home
|
New Git URL