Add condition variable for event loop

Instead of busy looping event thread, use a condition variable that is notified every time a command is sent or received, or every 100 milliseconds anyway.

Add condition variable for event loop
Instead of busy looping event thread, use a condition variable that is notified every time a command is sent or received, or every 100 milliseconds anyway.
Hayk Martirosyan
1 parent d5ad0507
Showing 2 changed files with 15 additions and 0 deletions
src/redox.cpp
src/redox.hpp
@@ -101,6 +101,10 @@ void Redox::run_event_loop() {
   while (!to_exit) {
     process_queued_commands();
     ev_run(evloop, EVRUN_NOWAIT);
+
+    // Wait until notified, or check every 100 milliseconds
+    unique_lock<mutex> ul(loop_waiter_lock);
+    loop_waiter.wait_for(ul, chrono::milliseconds(100));
   }
   cout << "[INFO] Stop signal detected." << endl;
@@ -177,6 +181,9 @@ void Redox::command_callback(redisAsyncContext *ctx, void *r, void *privdata) {
   // Increment the Redox object command counter
   rdx->cmd_count++;
+
+  // Notify to check the event loop
+  rdx->loop_waiter.notify_one();
 }
 /**
@@ -191,6 +198,10 @@ bool Redox::submit_to_server(Command&lt;ReplyT&gt;* c) {
     c->invoke_error(REDOX_SEND_ERROR);
     return false;
   }
+
+  // Notify to check the event loop
+  c->rdx->loop_waiter.notify_one();
+
   return true;
 }
@@ -187,6 +187,10 @@ private:
   std::mutex exit_waiter_lock;
   std::condition_variable exit_waiter;
+  // Condition variable to check the event loop
+  std::condition_variable loop_waiter;
+  std::mutex loop_waiter_lock;
+
   // Maps of each Command, fetchable by the unique ID number
   std::unordered_map<long, Command<redisReply*>*> commands_redis_reply;
   std::unordered_map<long, Command<std::string>*> commands_string_r;