threadedadaptivecommscomponent([queuelengths]) -> new threadedadaptivecommscomponent

Base class for a version of an Axon adaptivecommscomponent that runs main() in a separate thread (meaning it can, for example, block).

Subclass to make your own.

Internal queues buffer data between the thread and the Axon inboxes and outboxes of the component. Set the default queue length at initialisation (default=1000).

Like an adaptivecommscomponent, inboxes and outboxes can be added and deleted at runtime.

A simple example:

class IncrementByN(Axon.ThreadedComponent.threadedcomponent):

    Inboxes = { "inbox" : "Send numbers here",
                "control" : "NOT USED",
              }
    Outboxes = { "outbox" : "Incremented numbers come out here",
                "signal" : "NOT USED",
               }

    def __init__(self, N):
        super(IncrementByN,self).__init__()
        self.n = N

    def main(self):
        while 1:
            while self.dataReady("inbox"):
                value = self.recv("inbox")
                value = value + self.n
                self.send(value,"outbox")

            if not self.anyReady():
                self.pause()

Methods inherited from Axon.ThreadedComponent.threadedcomponent :

• initialiseComponent(self)
• _handlemessagefromthread(self, msg)
• activate(self[, Scheduler][, Tracker][, mainmethod])
• mainBody(self)
• recv(self[, boxname])
• forwardInboxToThread(self, box)
• closeDownComponent(self)
• unlink(self[, thecomponent][, thelinkage])
• sync(self)
• send(self, message[, boxname])
• _threadmain(self)
• pause(self[, timeout])
• _localmain(self)
• _do_threadsafe(self, cmd, argL, argD)
• link(self, source, sink[, passthrough])
• main(self)
• dataReady(self[, boxname])

Methods inherited from Axon.Component.component :

• __str__(self)
• childComponents(self)
• setInboxSize(self, boxname, size)
• anyReady(self)
• __addChild(self, child)
• _closeDownMicroprocess(self)
• _deliver(self, message[, boxname])
• removeChild(self, child)
• Inbox(self[, boxname])
• addChildren(self, *children)

Methods inherited from Axon.Microprocess.microprocess :

• _unpause(self)
• _microprocessGenerator(self, someobject[, mainmethod])
• _isStopped(self)
• stop(self)
• next(self)
• unpause(self)
• run(self)
• _isRunnable(self)

Methods inherited from Axon.AdaptiveCommsComponent._AdaptiveCommsable :

• retrieveTrackedResource(self, inbox)
• _newOutboxName(self[, name])
• ceaseTrackingResource(self, resource)
• trackResource(self, resource, inbox)
• retrieveTrackedResourceInformation(self, resource)
• _newInboxName(self[, name])
• trackResourceInformation(self, resource, inboxes, outboxes, information)