diff --git a/hazelcast/reactor.py b/hazelcast/reactor.py index a92de21b5d..8eea6968d6 100644 --- a/hazelcast/reactor.py +++ b/hazelcast/reactor.py @@ -6,7 +6,7 @@ import sys import threading import time -from Queue import PriorityQueue +from Queue import PriorityQueue, Empty from collections import deque from hazelcast.connection import Connection, BUFFER_SIZE @@ -55,7 +55,10 @@ def _check_timers(self): return if timer.check_timer(now): - self._timers.get_nowait() + try: + self._timers.get_nowait() + except Empty: + pass else: return