Extended thread dispatching support.
For basic support see reactor threading API docs.
| 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 | callMultipleInThread |
Run a list of functions in the same thread. |
| Function | deferToThread |
Run a function in a thread and return the result as a Deferred. |
| Function | deferToThreadPool |
Call the function f using a thread from the given threadpool and return the result as a Deferred. |
| Function | _runMultiple |
Run a list of functions. |
Deferred, wait for its result and return that.| Parameters | |
| reactor | The IReactorThreads provider which will be used to schedule the function call. |
| f:any callable. | the callable to run in the reactor thread |
| *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 | |
Exception | 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). |
Run a list of functions in the same thread.
tupleList should be a list of (function, argsList, kwargsDict) tuples.
| 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. | |
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. | |