heapq.heappush(tasks, task)
return task
-def loop(timeout=30.0):
+def loop(timeout=30.0, use_poll=False):
global running
running = True
oldhandler = signal.signal(signal.SIGTERM, exit)
if tasks:
t = max(min(t, tasks[0].time - now), 0)
- asyncore.poll(timeout=t)
+ asyncore.loop(timeout=t, count=1, use_poll=use_poll)
signal.signal(signal.SIGTERM, oldhandler)