class twisted._threads.ThreadWorker: (source)
Implements interfaces: twisted._threads._ithreads.IExclusiveWorker
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 |
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 . (type: Queue ) |
Perform the given task on the thread owned by this ThreadWorker
.
Parameters | task | the function to call on a thread. |