Package grassyknoll :: Package concurrent :: Module Worker :: Class PrivateBoxWorker
[hide private]

Class PrivateBoxWorker

source code


A Worker with a private MailBox.

Instance Methods [hide private]
 
__init__(self, inbox_timeout=15, *args, **kwargs) source code
 
__timeout(self) source code
tuple
checkMessages(self)
check for new Messages for this worker
source code

Inherited from Worker: callFunc, doExits, run, sendReply

Inherited from threading.Thread: __repr__, getName, isAlive, isDaemon, join, setDaemon, setName, start

Inherited from threading.Thread (private): _set_daemon

Inherited from threading._Verbose (private): _note

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __setattr__, __str__

Class Variables [hide private]

Inherited from Worker: logger

Instance Variables [hide private]
float inbox_timeout
how long, in seconds, to block on an empty inbox before trying privbox again.
MailBox.ThreadMailBox privbox
a private box for this thread.

Inherited from Worker: context, context_factory, inbox, newcontext, unhandled

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, inbox_timeout=15, *args, **kwargs)
(Constructor)

source code 
Overrides: Worker.__init__

checkMessages(self)

source code 
check for new Messages for this worker
Returns: tuple
a Message and the the MailBox.MailBox it came from.
Overrides: Worker.checkMessages
(inherited documentation)

Instance Variable Details [hide private]

inbox_timeout

how long, in seconds, to block on an empty inbox before trying privbox again. The actual wait time will be +/- 25%.
Type:
float