diff --git a/tarantool/connection_pool.py b/tarantool/connection_pool.py
index f1e675b3..1734402a 100644
--- a/tarantool/connection_pool.py
+++ b/tarantool/connection_pool.py
@@ -660,8 +660,12 @@ def _request_process_loop(self, key, unit, last_refresh):
         """
 
         while unit.request_processing_enabled:
-            if not unit.input_queue.empty():
-                task = unit.input_queue.get()
+            try:
+                task = unit.input_queue.get(timeout=self.refresh_delay)
+            except queue.Empty:
+                task = None
+
+            if task:
                 method = getattr(Connection, task.method_name)
                 try:
                     resp = method(unit.conn, *task.args, **task.kwargs)