FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
taskflow/benchmarks/wavefront/omp.cpp at task_isolation · ModuleWorks/taskflow · GitHub
ModuleWorks
/
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
taskflow
/
benchmarks
/
wavefront
/
omp.cpp
Copy path
More file actions
More file actions
Latest commit
History
History
History
82 lines (72 loc) · 2.14 KB
Breadcrumbs
taskflow
/
benchmarks
/
wavefront
/
omp.cpp
Copy path
File metadata and controls
82 lines (72 loc) · 2.14 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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
#
include
"
matrix.hpp
"
#
include
<
omp.h
>
int
**D {
nullptr
};
//
wavefront computation
void
wavefront_omp
(
unsigned
num_threads) {
//
set up the dependency matrix
D =
new
int
*[
MB
];
for
(
int
i=
0
; i<
MB
; ++i) D[i] =
new
int
[
NB
];
for
(
int
i=
0
; i<
MB
; ++i){
for
(
int
j=
0
; j<
NB
; ++j){
D[i][j] =
0
;
}
}
omp_set_num_threads
(num_threads);
#
pragma
omp parallel
{
#
pragma
omp single
{
matrix[M-
1
][N-
1
] =
0
;
for
(
int
k=
1
; k <=
2
*
MB
-
1
; k++) {
int
i, j;
if
(k <=
MB
){
i = k-
1
;
j =
0
;
}
else
{
//
assume matrix is square
i =
MB
-
1
;
j = k-
MB
;
}
for
(; (k <=
MB
&& i>=
0
) || (k >
MB
&& j <=
NB
-
1
) ; i--, j++){
if
(i >
0
&& j >
0
){
#
pragma
omp task depend(in:D[i-1][j], D[i][j-1]) depend(out:D[i][j]) firstprivate(i, j)
block_computation
(i, j);
}
//
top left corner
else
if
(i ==
0
&& j ==
0
){
#
pragma
omp task depend(out:D[i][j]) firstprivate(i, j)
block_computation
(i, j);
}
//
top edge
else
if
(j+
1
<=
NB
&& i ==
0
&& j >
0
){
#
pragma
omp task depend(in:D[i][j-1]) depend(out:D[i][j]) firstprivate(i, j)
block_computation
(i, j);
}
//
left edge
else
if
(i+
1
<=
MB
&& i >
0
&& j ==
0
){
#
pragma
omp task depend(in:D[i-1][j]) depend(out:D[i][j]) firstprivate(i, j)
block_computation
(i, j);
}
//
bottom right corner
else
if
(i ==
MB
-
1
&& j ==
NB
-
1
){
#
pragma
omp task depend(in:D[i-1][j] ,D[i][j-1]) firstprivate(i, j)
block_computation
(i, j);
}
else
{
assert
(
false
);
}
}
}
#
pragma
omp taskwait
}
}
for
(
int
i =
0
; i <
MB
; ++i )
delete []
D[i];
delete []
D;
}
std::chrono::microseconds
measure_time_omp
(
unsigned
num_threads) {
auto
beg =
std::chrono::high_resolution_clock::now
();
wavefront_omp
(num_threads);
auto
end =
std::chrono::high_resolution_clock::now
();
return
std::chrono::duration_cast<std::chrono::microseconds>(end - beg);
}
Back
|
FazBrowse Home
|
New Git URL