twisted._threads.ThreadWorker : API documentation

An IExclusiveWorker implemented based on a single thread and a queue.

This worker ensures exclusivity (i.e. it is an IExclusiveWorker and not an IWorker) by performing all of the work passed to do on the same thread.

Method	__init__	Create a `ThreadWorker` with a function to start a thread and a queue to use to communicate with that thread.
Method	do	Perform the given task on the thread owned by this `ThreadWorker`.
Method	quit	Reject all future work and stop the thread started by `__init__`.
Instance Variable	_q	Undocumented
Instance Variable	_hasQuit	Undocumented

def __init__(self, startThread, queue): (source)

Create a ThreadWorker with a function to start a thread and a queue to use to communicate with that thread.

Parameters	startThread	a callable that takes a callable to run in another thread. (type: callable taking a 0-argument callable and returning nothing.)
	queue	A `Queue` to use to give tasks to the thread created by `startThread`.
	queue	`Queue`

_q =

Undocumented

_hasQuit =

Undocumented

def do(self, task): (source)

from twisted._threads.IWorker

Perform the given task on the thread owned by this ThreadWorker.

Parameters task the function to call on a thread.

def quit(self): (source)

from twisted._threads.IWorker

Reject all future work and stop the thread started by __init__.

twisted._threads.ThreadWorker(object) class documentation

`twisted._threads.ThreadWorker(object)` class documentation