class RequestingFanList
RequestingFanList writes a signal to the outRequestAny channel; it then reads an object from inResponseAny and then writes the input object to the next element of outputList in sequence.
Once the UniversalTerminator is read it will be copied to all of the outputList channel ends. The incoming data is not modified in any manner.
Typically this process will be used to send a request for data to a process on another node in a cluster based system.
Behaviour: currentIndex = 0 while true outRequestAny.write(signal) outputList[currentIndex].write( inResponseAny.read() ) currentIndex = (currentIndex + 1) modulus outputList.size()
outRequestAny
- A one2any Channel used to write a signal to a previous OneFanRequestedAny processinResponseAny
- A one2Any Channel used to read an incoming data object from the previous processoutputList
- A channel output list to which the incoming data object is writtenType | Name and description |
---|---|
ChannelInput |
inResponseAny |
ChannelOutput |
outRequestAny |
ChannelOutputList |
outputList |
Constructor and description |
---|
RequestingFanList
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk