adams.flow.control.LoadBalancer
Runs the specified 'load actor' in as many separate threads as specified with the 'num-threads' parameter.
Always uses a copy of the variables.
NB: no callable transformer or sink allowed.
Flow input/output:
- input: adams.flow.core.Unknown
Actor handler information:
- Actor execution: SEQUENTIAL
- Standalones allowed: true
- Source allowed: true
- Forwards input: true
The logging level for outputting errors and debugging output.
command-line | -logging-level <OFF|SEVERE|WARNING|INFO|CONFIG|FINE|FINER|FINEST> |
default | WARNING |
min-user-mode | Expert |
The name of the actor.
command-line | -name <java.lang.String> |
default | LoadBalancer |
The annotations to attach to this actor.
command-line | -annotation <adams.core.base.BaseAnnotation> |
default |
|
If set to true, transformation is skipped and the input token is just forwarded as it is.
command-line | -skip <boolean> |
default | false |
If set to true, the flow execution at this level gets stopped in case this actor encounters an error; the error gets propagated; useful for critical actors.
command-line | -stop-flow-on-error <boolean> |
default | false |
min-user-mode | Expert |
If enabled, then no errors are output in the console; Note: the enclosing actor handler must have this enabled as well.
command-line | -silent <boolean> |
default | false |
min-user-mode | Expert |
The actors to 'load-balance'.
command-line | -load <adams.flow.core.Actor> [-load ...] |
default | adams.flow.sink.Null |
The number of threads to use for load-balancing (-1 means one for each core/cpu).
command-line | -num-threads <int> |
default | 0 |
If enabled, then each thread will restrict the scope of storage to be local; initially, a shallow copy of the storage is taken at the thread's time of creation.
command-line | -use-local-storage <boolean> |
default | false |
If enabled, the local storage gets copied using a deep copy.
command-line | -deep-copy <boolean> |
default | false |