Home | Trees | Indices | Help |
---|
|
Exchange --+ | Map
An exchange which can be used like the built-in 'map' function.
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
Inherited from |
|
Initialise the exchange with an optional list of 'channels'. If the optional 'limit' is specified, restrictions on the addition of new channels can be enforced and observed through the 'add_wait', 'wait' and 'finish' methods. To make use of these methods, create a subclass of this class and define a working 'store_data' method. If the optional 'reuse' parameter is set to a true value, channels and processes will be reused for waiting computations. If the optional 'autoclose' parameter is set to a false value, channels will not be closed automatically when they are removed from the exchange - by default they are closed when removed.
|
Add the given 'channel' to the exchange.
|
Using pprocess.start, create a new process for the given 'callable' using any additional arguments provided. Then, monitor the channel created between this process and the created process.
|
Using pprocess.create, create a new process and return the created communications channel to the created process. In the creating process, return None - the channel receiving data from the created process will be automatically managed by this exchange.
|
Accumulate the incoming data, associating results with channels.
|
Home | Trees | Indices | Help |
---|
Generated by Epydoc 3.0beta1 on Sat May 10 16:45:55 2008 | http://epydoc.sourceforge.net |