8000
We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 25bcef1 commit e2403bdCopy full SHA for e2403bd
asyncio/asyncio.py
@@ -39,13 +39,17 @@ def wait(self, delay):
39
time.sleep(delay)
40
41
def run_forever(self):
42
- while self.q:
43
-# t, cnt, cb, args = self.q.pop(0)
44
- t, cnt, cb, args = heapq.heappop(self.q)
45
- tnow = self.time()
46
- delay = t - tnow
47
- if delay > 0:
48
- self.wait(delay)
+ while True:
+ if self.q:
+ t, cnt, cb, args = heapq.heappop(self.q)
+ tnow = self.time()
+ delay = t - tnow
+ if delay > 0:
+ self.wait(delay)
49
+ else:
50
+ self.wait(-1)
51
+ # Assuming IO completion scheduled some tasks
52
+ continue
53
if callable(cb):
54
cb(*args)
55
else:
0 commit comments