|
__init__(self,
channels=None,
limit=None,
reuse=0,
continuous=0,
autoclose=1)
Initialise the exchange with an optional list of 'channels'. |
source code
|
|
|
add(self,
channel)
Add the given 'channel' to the exchange. |
source code
|
|
|
active(self)
Return a list of active channels. |
source code
|
|
|
ready(self,
timeout=None)
Wait for a period of time specified by the optional 'timeout' in
milliseconds (or until communication is possible) and return a list of
channels which are ready to be read from. |
source code
|
|
|
remove(self,
channel)
Remove the given 'channel' from the exchange. |
source code
|
|
|
unfinished(self)
Return whether the exchange still has work scheduled or in progress. |
source code
|
|
|
busy(self)
Return whether the exchange uses as many channels as it is allowed to. |
source code
|
|
|
add_wait(self,
channel)
Add the given 'channel' to the exchange, waiting if the limit on active
channels would be exceeded by adding the channel. |
source code
|
|
|
wait(self)
Test for the limit on channels, blocking and reading incoming data until
the number of channels is below the limit. |
source code
|
|
|
finish(self)
Finish the use of the exchange by waiting for all channels to complete. |
source code
|
|
|
store(self,
timeout=None)
For each ready channel, process the incoming data. |
source code
|
|
|
|
|
_get_waiting(self,
channel)
Get waiting callable and argument information for new processes, given
the reception of data on the given 'channel'. |
source code
|
|
|
_set_waiting(self,
callable,
args,
kw)
Support process creation by returning whether the given 'callable' has
been queued for later invocation. |
source code
|
|
|
_get_channel_for_process(self,
channel)
Support process creation by returning the given 'channel' to the
creating process, and None to the created process. |
source code
|
|
|
start_waiting(self,
channel)
Start a waiting process given the reception of data on the given
'channel'. |
source code
|
|
|
start(self,
callable,
*args,
**kw)
Create a new process for the given 'callable' using any additional
arguments provided. |
source code
|
|
|
create(self)
Create a new process and return the created communications channel to
the created process. |
source code
|
|
|
manage(self,
callable)
Wrap the given 'callable' in an object which can then be called in the
same way as 'callable', but with new processes and communications
managed automatically. |
source code
|
|