FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
cpp-taskflow/examples/run.cpp at master · feiyunwill/cpp-taskflow · GitHub
feiyunwill
/
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
/
examples
/
run.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
66 lines (52 loc) · 2.09 KB
Breadcrumbs
cpp-taskflow
/
examples
/
run.cpp
Copy path
File metadata and controls
66 lines (52 loc) · 2.09 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.
#
include
<
taskflow/taskflow.hpp
>
int
main
(){
//
create an executor and a taskflow
tf::Executor
executor
(
1
);
tf::Taskflow
taskflow
(
"
Demo
"
);
auto
A = taskflow.
emplace
([&](){ std::cout <<
"
TaskA
\n
"
; }).
name
(
"
A
"
);
auto
B = taskflow.
emplace
([&](tf::Subflow& 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);
//
dumpping a taskflow before execution won't visualize subflow tasks
std::cout <<
"
Dump the taskflow before execution:
\n
"
;
taskflow.
dump
(std::cout);
std::cout <<
"
Run the taskflow once without callback
\n
"
<< std::endl;
executor.
run
(taskflow).
get
();
std::cout << std::endl;
//
after execution, we can visualize subflow tasks
std::cout <<
"
Dump the taskflow after execution:
\n
"
;
taskflow.
dump
(std::cout);
std::cout << std::endl;
std::cout <<
"
Use wait_for_all to wait for the execution to finish
\n
"
;
executor.
run
(taskflow).
get
();
executor.
wait_for_all
();
std::cout << std::endl;
std::cout <<
"
Execute the taskflow two times without a callback
\n
"
;
executor.
run
(taskflow).
get
();
std::cout <<
"
Dump after two executions:
\n
"
;
taskflow.
dump
(std::cout);
std::cout << std::endl;
std::cout <<
"
Execute the taskflow four times with a callback
\n
"
;
executor.
run_n
(taskflow,
4
, [] () { std::cout <<
"
finishes 4 runs
\n
"
; })
.
get
();
std::cout << std::endl;
std::cout <<
"
Run the taskflow until the predicate returns true
\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