asynqueue.null.NullQueue(TaskQueue) class documentation
Part of asynqueue.null
(View In Hierarchy)
A TaskQueue
that runs tasks in the Twisted main loop.
| Method | __init__ |
Inherited from TaskQueue:
| Method | __len__ | Returns my "length" as the number of workers currently at my disposal. |
| Method | __bool__ | I evaluate as True if I am running and have at least one
worker. |
| Method | isRunning | Returns True if shutdown has not been initiated and both my
task handler and queue are running, False otherwise. |
| Method | shutdown | You must call this and wait for the Deferred it returns
when you're done with me. Calls Queue.shutdown,
among other things. |
| Method | attachWorker | Registers a new provider of IWorker for working on tasks
from the queue. |
| Method | detachWorker | Detaches and terminates the worker supplied or specified by its ID. |
| Method | qualifyWorker | Adds the specified series to the qualifications of the supplied worker. |
| Method | workers | Returns the worker object specified by ID, or None
if that worker is not employed with me. |
| Method | taskDone | Processes the status/result tuple from a worker running a task. You don't need to call this directly. |
| Method | newTask | Makes a new tasks.Task object from a
func-args-kw combo. You won't call this directly. |
| Method | call | Queues up a function call. |
| Method | update | Sets an update task from func with any supplied arguments and keywords to be run directly on all current and future workers. |
| Method | _getWorkerID | Undocumented |
def
__init__(self, **kw):
overrides asynqueue.base.TaskQueue.__init__
| Parameters | kw | Keywords for the regular TaskQueue
constructor. |