Refactored schedulers

.travis.yml

@@ -2,9 +2,8 @@ language: python
 sudo: false
 python:
 - 2.7
-- 3.3
-- 3.4
 - 3.5
+- 3.6
 - pypy
 before_install:
 - |

promise/__init__.py

@@ -24,11 +24,7 @@
         get_default_scheduler,
         set_default_scheduler
     )
-    from .scheduler import SyncScheduler
-    try:
-        from .thread_sheduler import ThreadScheduler
-    except ImportError:
-        ThreadScheduler = None
+    from .schedulers.immediate import ImmediateScheduler
 
     __all__ = [
         'Promise',
@@ -38,6 +34,5 @@
         'async_instance',
         'get_default_scheduler',
         'set_default_scheduler',
-        'SyncScheduler',
-        'ThreadScheduler'
+        'ImmediateScheduler'
     ]

promise/async_.py

@@ -6,8 +6,8 @@ class Async(object):
 
     def __init__(self, schedule):
         self.is_tick_used = False
-        self.late_queue = collections.deque()
-        self.normal_queue = collections.deque()
+        self.late_queue = collections.deque()  # type: ignore
+        self.normal_queue = collections.deque()  # type: ignore
         self.have_drained_queues = False
         self.trampoline_enabled = False
         self.schedule = schedule

promise/promise.py

@@ -13,11 +13,12 @@
                      iterate_promise)
 from .utils import deprecated, integer_types, string_types, text_type, binary_type, warn
 from .promise_list import PromiseList
-from .scheduler import SyncScheduler
-# from .gevent_scheduler import GeventScheduler
-# from .thread_scheduler import ThreadScheduler
+from .schedulers.immediate import ImmediateScheduler
+# from .schedulers.gevent import GeventScheduler
+# from .schedulers.asyncio import AsyncioScheduler
+# from .schedulers.thread import ThreadScheduler
 
-async_instance = Async(SyncScheduler())
+async_instance = Async(ImmediateScheduler())
 
 
 def get_default_scheduler():

promise/schedulers/asyncio.py

@@ -0,0 +1,11 @@
+from __future__ import absolute_import
+
+from asyncio import get_event_loop
+
+
+class AsyncioScheduler(object):
+    def __init__(self, loop=None):
+        self.loop = loop or get_event_loop()
+
+    def call(self, fn):
+        self.loop.call_soon(fn)

promise/gevent_scheduler.py → promise/schedulers/gevent.py

@@ -1,13 +1,17 @@
+from __future__ import absolute_import
+
 from gevent.event import Event
 import gevent
 
+
 class GeventScheduler(object):
     def call(self, fn):
         # print fn
         gevent.spawn(fn)
 
     def wait(self, promise, timeout=None):
         e = Event()
+
         def on_resolve_or_reject(_):
             e.set()
 

promise/scheduler.py → promise/schedulers/immediate.py

@@ -1,7 +1,7 @@
 from threading import Event
 
 
-class SyncScheduler(object):
+class ImmediateScheduler(object):
     def call(self, fn):
         try:
             fn()
@@ -10,6 +10,7 @@ def call(self, fn):
 
     def wait(self, promise, timeout=None):
         e = Event()
+
         def on_resolve_or_reject(_):
             e.set()
 

promise/thread_scheduler.py → promise/schedulers/thread.py

@@ -8,6 +8,7 @@ def call(self, fn):
 
     def wait(self, promise, timeout=None):
         e = Event()
+
         def on_resolve_or_reject(_):
             e.set()