diff --git a/src/connection.c b/src/connection.c
index fea092b..a6e2b34 100644
--- a/src/connection.c
+++ b/src/connection.c
@@ -127,6 +127,15 @@
 			if (!conn->subs->events)
 				conn->subs = NULL;
 		}
+		else if (tasks_run_queue_cur >= 16*global.tune.runqueue_depth) {
+			/* In order to save syscalls especially with epoll, we
+			 * prefer *not* to disable receiving and instead let
+			 * the handler do its job. But if the run queue becomes
+			 * high, the excess of events may cause extra wakeups
+			 * and in this case we'd rather flow-control ourselves.
+			 */
+			fd_stop_recv(fd);
+		}
 	}
 
  leave: