These processes are commonly used to plumb/plug/glue together your network.
Many of the processes seem to do similar things to each other, and in fact certain combinations of processes are equivalent to other arrangements:
Putting an ExtId process to connect two channels has no effect on the synchronization. This can be used to your advantage. For example, you may find yourself wanting to use a Merger on two channels, but the input channels to it are One2AnyChannel, which do not support alting. If you connect each One2AnyChannel to an ExtId process, and connect the ExtId processes to the Merger process using One2OneChannel, your problem will be solved.
Classes | |
class | BarrierSyncer |
This process syncs on a barrier a specified number of times, then finishes. More... | |
class | BucketFlusher |
This process flushes a given bucket every time it is sent "true" on its channel, and quits when it is sent "false". More... | |
class | ChannelPoisoner |
Poisons the end of a channel and then exits. More... | |
class | EvaluateFunction |
Evaluates a function and sends out the output. More... | |
class | ExtId |
A process that forever performs an extended input from a channel, sending the data out on another channel as its extended action. More... | |
class | ExtMerger |
Merges the data from multiple channels into one, using extended input to prevent buffering. More... | |
class | ExtSyncId |
A process that forever performs an extended input from a channel, and for its extended action: syncs on a barrier and then sends the data out on another channel. More... | |
class | FunctionProcess |
This process acts like an Id process, but applies a transformation to the data before sending it on. More... | |
class | Id |
A process that forever forwards an item of data to another channel. More... | |
class | Merger |
Merges the data from multiple channels into one. More... | |
class | NotifySender |
A process that behaves like Id -- continually reading values and then sending them on -- but with acknowledgements when the message has been sent on. More... | |
class | Prefix |
A process that forwards an item of data to another channel, but starts by sending a supplied initial value. More... | |
class | ReaderProcess |
Reads values from a channel a specified number of times. More... | |
class | ReadOnceProcess |
Reads a single value from a channel into a given (by pointer) location. More... | |
class | SeqDelta |
A process that forever forwards an item of data to two other channels -- in sequence. More... | |
class | SkipProcess |
A process that does nothing. More... | |
class | SleepForProcess |
A process that sleeps for a specified amount of time. More... | |
class | SleepUntilProcess |
A process that sleeps until a specified time. More... | |
class | Successor |
A process that reads a value from its input channel, increments it, and writes it to the process's output channel. More... | |
class | WriteOnceProcess |
Writes a given value (passed by pointer) to a channel once. More... | |
class | WriterProcess |
Writes a given value to a channel a specified number of times. More... |