class ListGroupCollect
A ListGroupCollect is a Group with an internal Collect process rather than a Worker. This has the effect of running all the Collect processes in parallel. It is assumed that any results are fully processed by the GroupCollect as there are no output channels connected to the processes.
It is assumed that it is not possible to write to the same (or part of a) data object in more than ONE of the Collectors. In other words parallel access to a data object is not permitted for write operations where the operation does not have exclusive access to the data object. This is a requirement but is not checked by the system. There is no synchronisation between the Collectors in the group.
inputList
- A ChannelInputList with as many channels as the value of workers.
Each Collect process reads from just one element of the input.rDetails
- A ResultDetails object defining the result class used by the Collect processworkers
- The number of Collect processes that will be created
when the Group is runlogFileName
- is a string value specifying that the log output should be written to a file rather than the console.
The filename string should contain the full pathe name. The suffix.log will be added to the file name. Each log file in
the group will be identified by its index.Type | Name and description |
---|---|
ChannelInputList |
inputList |
String |
logFileName |
ResultDetails |
rDetails |
int |
workers |
Constructor and description |
---|
ListGroupCollect
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk