class ListParOne
ListParOne is used to connect many source processes to one destination process such that incoming data objects will be read in parallel from all elements of the input channel list and then written in sequence to the next process using the output channel.
Once a UniversalTerminator object has been read from all the source processes, in parallel, the process will then output a single UniversalTerminator object. The incoming data is not modified in any manner.
Behaviour: while true values = inputList.read() for ( i in 0..< inputList.size()) output.write( values[i] )
output
- A one2one Channel used to write data objects to the next processinputList
- A ChannelInputList from which incoming data objects are read in sequenceType | Name and description |
---|---|
ChannelInputList |
inputList |
ChannelOutput |
output |
Constructor and description |
---|
ListParOne
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk