lpush_benchmark.cpp
1.13 KB
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
/**
* Basic asynchronous calls using redox.
*/
#include <iostream>
#include "../src/redox.hpp"
using namespace std;
double time_s() {
unsigned long ms = chrono::system_clock::now().time_since_epoch() / chrono::microseconds(1);
return (double)ms / 1e6;
}
int main(int argc, char* argv[]) {
redox::Redox rdx;
rdx.start();
rdx.del("test");
double t0 = time_s();
double t1 = t0;
int len = 1000000;
atomic_int count = {0};
for(int i = 1; i <= len; i++) {
rdx.command<int>("lpush test 1", [&t0, &t1, &count, len, &rdx](const string& cmd, int reply) {
count += 1;
if(count == len) {
cout << cmd << ": " << reply << endl;
double t2 = time_s();
cout << "Time to queue async commands: " << t1 - t0 << "s" << endl;
cout << "Time to receive all: " << t2 - t1 << "s" << endl;
cout << "Total time: " << t2 - t0 << "s" << endl;
cout << "Result: " << (double)len / (t2-t0) << " commands/s" << endl;
rdx.stop_signal();
}
});
}
t1 = time_s();
rdx.block();
cout << "Commands processed: " << rdx.num_commands_processed() << endl;
return 0;
};