Implements interfaces: twisted.internet.interfaces.IPushProducer

Produces task queue loading information.

I produce information about the current load of a TaskQueue. The information consists of the number of tasks currently queued, and is written as a single integer to my consumers as a single integer whenever a task is queued up and again when it is completed.

Instance Variable	consumer	A list of the consumers for whom I'm producing information.
Method	__init__	Undocumented
Method	registerConsumer	Call this with a provider of `IConsumer` and I'll produce for it in addition to any others already registered with me.
Method	shutdown	Stop me from producing and unregister any consumers I have.
Method	oneLess	Undocumented
Method	oneMore	Undocumented
Method	pauseProducing	Undocumented
Method	resumeProducing	Undocumented
Method	stopProducing	Undocumented
Method	_update	Undocumented

consumer =

A list of the consumers for whom I'm producing information.

def __init__(self):

Undocumented

def registerConsumer(self, consumer):

Call this with a provider of IConsumer and I'll produce for it in addition to any others already registered with me.

def shutdown(self):

Stop me from producing and unregister any consumers I have.

def oneLess(self):

Undocumented

def oneMore(self):

Undocumented

def _update(self, increment):

Undocumented

def pauseProducing(self):

Undocumented

def resumeProducing(self):

Undocumented

def stopProducing(self):

Undocumented

API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.

asynqueue.base.LoadInfoProducer(object) class documentation

`asynqueue.base.LoadInfoProducer(object)` class documentation