pep/slixmpp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Use a deque for the idle list

Browse source
This commit is contained in:
Florent Le Coz 2015-01-03 16:13:39 +01:00
parent 47fbd4cead
commit 565da65ccd
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
slixmpp/xmlstream/asyncio.py
View file

@ -9,6 +9,8 @@ call_soon() ones. These callback are called only once each.
import asyncio import asyncio
from asyncio import tasks, events from asyncio import tasks, events
import collections
def idle_call(self, callback): def idle_call(self, callback):
if tasks.iscoroutinefunction(callback): if tasks.iscoroutinefunction(callback):
raise TypeError("coroutines cannot be used with idle_call()") raise TypeError("coroutines cannot be used with idle_call()")
@ -20,12 +22,12 @@ def my_run_once(self):
self._ready.append(events.Handle(lambda: None, (), self)) self._ready.append(events.Handle(lambda: None, (), self))
real_run_once(self) real_run_once(self)
if self._idle: if self._idle:
handle = self._idle.pop(0) handle = self._idle.popleft()
handle._run() handle._run()
cls = asyncio.get_event_loop().__class__ cls = asyncio.get_event_loop().__class__
cls._idle = [] cls._idle = collections.deque()
cls.idle_call = idle_call cls.idle_call = idle_call
real_run_once = cls._run_once real_run_once = cls._run_once
cls._run_once = my_run_once cls._run_once = my_run_once