Speed up I/O processing by processing batches of events

Author: sedwards2009

qode/integration/node_integration.cc

@@ -19,6 +19,9 @@ NodeIntegration::NodeIntegration()
       embed_closed_(false) {
 }
 
+constexpr uint64_t EVENT_BATCH_TIMEOUT_MS = 8;
+constexpr int EVENT_BATCH_SIZE = 64;
+
 NodeIntegration::~NodeIntegration() {
   // Quit the embed thread.
   embed_closed_ = true;
@@ -76,6 +79,17 @@ void NodeIntegration::ReleaseHandleRef() {
 void NodeIntegration::WakeupMainThread() {
   PostTask([this] {
     this->UvRunOnce();
+    // ^ This also updates the uv_now() timestamp.
+    uint64_t start_time_ms = uv_now(uv_loop_);
+
+    int loop_count = EVENT_BATCH_SIZE;
+    uint64_t elapsed_ms = 0;
+    while (loop_count != 0 && (elapsed_ms < EVENT_BATCH_TIMEOUT_MS)) {
+      loop_count--;
+      this->UvRunOnce();
+      elapsed_ms = uv_now(uv_loop_) - start_time_ms;
+    }
+
     // Tell the worker thread to continue polling.
     uv_sem_post(&this->embed_sem_);
   });