class ListFanOne extends Object
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 sequenceConstructor and description |
---|
ListFanOne
() |
GPP - Groovy Parallel Patterns generated test by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk