Extended thread dispatching support.
For basic support see reactor threading API docs.
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.
This function is only used by client code which is maintaining its own
threadpool. To run a function in the reactor's threadpool, use
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. |
Run a function in a thread and return the result as a Deferred.
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.
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.
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 ). |