basic_threaded.cpp
894 Bytes
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
/**
*
*/
#include <iostream>
#include <chrono>
#include <thread>
#include "redox.hpp"
using namespace std;
using redox::Redox;
using redox::Command;
redox::Redox rdx = {"localhost", 6379};
int main(int argc, char* argv[]) {
if(!rdx.connect()) return 1;
thread setter([]() {
for(int i = 0; i < 5000; i++) {
rdx.command<int>("INCR counter");
this_thread::sleep_for(chrono::milliseconds(1));
}
cout << "Setter thread exiting." << endl;
});
thread getter([]() {
for(int i = 0; i < 5; i++) {
rdx.command<string>(
"GET counter",
[](Command<string>& c) {
if(c.ok()) cout << c.cmd() << ": " << c.reply() << endl;
}
);
this_thread::sleep_for(chrono::milliseconds(1000));
}
cout << "Getter thread exiting." << endl;
});
setter.join();
getter.join();
rdx.disconnect();
return 0;
};