Part of twisted.internet View Source
Extended thread dispatching support.
For basic support see reactor threading API docs.
Maintainer: Itamar Shtull-Trauring| Function | deferToThreadPool | Call the function f using a thread from the given
threadpool and return the result as a Deferred.
|
| Function | deferToThread | Run a function in a thread and return the result as a Deferred. |
| Function | callMultipleInThread | Run a list of functions in the same thread. |
| Function | blockingCallFromThread | Run a function in the reactor from a thread, and wait for the result
synchronously. If the function returns a Deferred, wait
for its result and return that.
|
| Function | _runMultiple | Run a list of functions. |
Call the function f using a thread from the given
threadpool and return the result as a Deferred.
deferToThread.
| Parameters | reactor | The reactor in whose main thread the Deferred will be invoked. |
| threadpool | An object which supports the callInThreadWithCallback
method of twisted.python.threadpool.ThreadPool.
| |
| f | The function to call. | |
| *args | positional arguments to pass to f. | |
| **kwargs | keyword arguments to pass to f. | |
| Returns | A Deferred which fires a callback with the result of f, or an errback
with a twisted.python.failure.Failure
if f throws an exception.
| |
| Parameters | f | The function to call. |
| *args | positional arguments to pass to f. | |
| **kwargs | keyword arguments to pass to f. | |
| Returns | A Deferred which fires a callback with the result of f, or an errback
with a twisted.python.failure.Failure
if f throws an exception.
| |
Run a list of functions in the same thread.
tupleList should be a list of (function, argsList, kwargsDict) tuples.Deferred, wait
for its result and return that.
| Parameters | reactor | The IReactorThreads
provider which will be used to schedule the function call.
|
| f | the callable to run in the reactor thread (type: any callable. ) | |
| a | the arguments to pass to f.
| |
| kw | the keyword arguments to pass to f.
| |
| Returns | the result of the Deferred
returned by f, or the result of f if it returns
anything other than a Deferred.
| |
| Raises | If f raises a synchronous exception,
blockingCallFromThread will raise that exception. If
f returns a Deferred which
fires with a Failure,
blockingCallFromThread will raise that failure's exception
(see Failure.raiseException).
| |