class ListFanOne
ListFanOne is used to connect many source processes to one destination process such that any incoming data object will be written to the next process using the output channel. The inputList is processed in a fair manner such that all active inputs are given equal access to the output bandwidth.
Once the UniversalTerminator is read from the any element of the input channel list, a UniversalTerminator object will be read from all the source processes. The process will then output a single UniversalTerminator object. The incoming data is not modified in any manner.
Behaviour: alt = new ALT(inputList) while true i = alt.fairSelect() output.write( inputList[i].read() )
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 |
---|
ListFanOne
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk