added callInGreenThread function to twisteds.util

This commit is contained in:
Denis Bilenko
2008-10-24 21:09:39 +07:00
parent 4162abb7e8
commit ecdc7f8687

View File

@@ -1,7 +1,7 @@
from functools import wraps from twisted.internet import defer
from eventlet.support.greenlet import greenlet from eventlet.support.greenlet import greenlet
from eventlet import greenlib from eventlet import greenlib
from eventlet.api import get_hub from eventlet.api import get_hub, spawn
def block_on(deferred): def block_on(deferred):
cur = greenlet.getcurrent() cur = greenlet.getcurrent()
@@ -12,3 +12,15 @@ def block_on(deferred):
deferred.addCallback(cb) deferred.addCallback(cb)
deferred.addErrback(eb) deferred.addErrback(eb)
return get_hub().switch() return get_hub().switch()
def callInGreenThread(func, *args, **kwargs):
result = defer.Deferred()
def signal_deferred():
try:
value = func(*args, **kwargs)
except Exception, ex:
result.errback(ex)
else:
result.callback(value)
spawn(signal_deferred)
return result