twisted.internet.threads : API documentation

def deferToThreadPool(reactor, threadpool, f, *args, **kwargs): (source)

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.

def deferToThread(f, *args, **kwargs): (source)

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.

def _runMultiple(tupleList): (source)

Run a list of functions.

def callMultipleInThread(tupleList): (source)

Run a list of functions in the same thread.

tupleList should be a list of (function, argsList, kwargsDict) tuples.

def blockingCallFromThread(reactor, f, *a, **kw): (source)

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	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`).

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.