-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.cpp
126 lines (107 loc) · 4.26 KB
/
main.cpp
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
118
119
120
121
122
123
124
125
126
#include "threadpool.hpp"
#include "task.hpp"
class task : public hpc::task_base {
private:
int block_ms;
int task_id;
bool verbose;
public:
task(int block_ms, int task_id, bool verbose) {
this->block_ms = block_ms;
this->task_id = task_id;
this->verbose = verbose;
};
void process() {
auto start = std::chrono::system_clock::now();
while (true) {
auto end = std::chrono::system_clock::now();
auto duration = std::chrono::duration_cast<std::chrono::microseconds>(end - start);
auto block_time = double(duration.count())
* std::chrono::microseconds::period::num
/ std::chrono::microseconds::period::den
* 1000;
if (block_time > block_ms) {
if (this->verbose) {
std::cout << "task_id:" << this->task_id
<< ", pid:" << getpid()
<< ", tid:" << gettid()
<< ", tidx:" << gettid() - getpid()
<< ", time:" << block_time << "ms"
<< std::endl;
}
break;
}
};
}
int get() {
this->wait();
return this->task_base::task_time;
}
};
int main() {
int loop = 1000;
int streams = 0;
int threads = 0;
bool affinity = true;
bool verbose = false;
class hpc::thread_pool<task> tp(streams, threads, affinity, verbose);
// sync api : direct
{
tp.reset_all();
auto start = std::chrono::system_clock::now();
auto id = loop;
while (id--) {
tp.sync(std::make_shared<task>(10, id, verbose), true);
}
auto end = std::chrono::system_clock::now();
auto duration = std::chrono::duration_cast<std::chrono::microseconds>(end - start);
auto block_time = double(duration.count())
* std::chrono::microseconds::period::num
/ std::chrono::microseconds::period::den;
std::cout << "Sync API(direct) Summary"
<< ", Whole Time: " << block_time << "s"
<< ", Avg Latency: " << block_time / loop * 1000 << "ms"
<< ", Avg QPS: " << loop / block_time
<< std::endl;
}
// sync api : run by async api
{
tp.reset_all();
auto start = std::chrono::system_clock::now();
auto id = loop;
while (id--) {
tp.sync(std::make_shared<task>(10, id, verbose), false);
}
auto end = std::chrono::system_clock::now();
auto duration = std::chrono::duration_cast<std::chrono::microseconds>(end - start);
auto block_time = double(duration.count())
* std::chrono::microseconds::period::num
/ std::chrono::microseconds::period::den;
std::cout << "Sync API(async) Summary"
<< ", Whole Time: " << block_time << "s"
<< ", Avg Latency: " << block_time / loop * 1000 << "ms"
<< ", Avg QPS: " << loop / block_time
<< std::endl;
}
// async api
{
tp.reset_all();
auto start = std::chrono::system_clock::now();
auto id = loop * std::thread::hardware_concurrency();
while (id--) {
tp.async(std::make_shared<task>(10, id, verbose));
}
tp.wait_all();
auto end = std::chrono::system_clock::now();
auto duration = std::chrono::duration_cast<std::chrono::microseconds>(end - start);
auto block_time = double(duration.count())
* std::chrono::microseconds::period::num
/ std::chrono::microseconds::period::den;
std::cout << "Async API Summary"
<< ", Whole Time: " << block_time << "s"
<< ", Avg Latency: " << block_time / loop * 1000 << "ms"
<< ", Avg QPS: " << loop * std::thread::hardware_concurrency() / block_time
<< std::endl;
}
return 0;
}