Skip to content

Commit

Permalink
Removed ThreadScheduler as normal requirement
Browse files Browse the repository at this point in the history
Some environments could have threading disabled, and therefore the threading import can resolve in an error.
This commit fixes that :)
  • Loading branch information
syrusakbary committed Apr 30, 2017
1 parent b2963d2 commit d140b8e
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 10 deletions.
6 changes: 5 additions & 1 deletion promise/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,11 @@
get_default_scheduler,
set_default_scheduler
)
from .scheduler import SyncScheduler, ThreadScheduler
from .scheduler import SyncScheduler
try:
from .thread_sheduler import ThreadScheduler
except ImportError:
ThreadScheduler = None

__all__ = [
'Promise',
Expand Down
9 changes: 0 additions & 9 deletions promise/scheduler.py
Original file line number Diff line number Diff line change
@@ -1,15 +1,6 @@
from threading import Thread


class SyncScheduler(object):
def call(self, fn):
try:
fn()
except:
pass


class ThreadScheduler(object):
def call(self, fn):
thread = Thread(target=fn)
thread.start()
7 changes: 7 additions & 0 deletions promise/thread_scheduler.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
from threading import Thread


class ThreadScheduler(object):
def call(self, fn):
thread = Thread(target=fn)
thread.start()

0 comments on commit d140b8e

Please sign in to comment.