class RequestingSeqCastAny
RequestingSeqCastAny writes a signal to the outRequestAny channel; it then reads an object from inResponseAny and then writes the input object to all the processes connected to the outputAny channel.
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: while true outRequestAny.write(signal) o = inResponseAny.read() for ( i in 1..destinations) outputAny.write(o.clone())
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 processoutputAny
- A channel output list to which the incoming data object is writtendestinations
- the number of processes connected to the outputAny channelType | Name and description |
---|---|
int |
destinations |
ChannelInput |
inResponseAny |
ChannelOutput |
outRequestAny |
ChannelOutput |
outputAny |
Constructor and description |
---|
RequestingSeqCastAny
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk