utility:producer consumer for each
Version: 0.0.0
Description
Allows to write a loop over operators by connecting data to iterate and by requesting the incrementally output merged.The chain of Operators are split into a first part: the producers and a second part: the consumers. These 2 parts will run asynchronously on 2 threads.
Inputs
| Input | Name | Expected type(s) | Description |
|---|---|---|---|
| Pin 0 Required | producer_consumer_iterableq | The result of the make_producer_consumer_for_each_iterator operator. | |
| Pin 3 Required | forward | output of the last operators of the workflow |
Outputs
| Output | Name | Expected type(s) | Description |
|---|---|---|---|
| Pin 0 | empty | ||
| Pin 3 | output |
Configurations
| Name | Expected type(s) | Default value | Description |
|---|---|---|---|
| evaluate_inputs_before_run | bool | false | If this option is set to true, all input pins of the operator will be evaluated before entering the run method to maintain a correct Operator status. |
| mutex | bool | false | If this option is set to true, the shared memory is prevented from being simultaneously accessed by multiple threads. |
Scripting
Category: utility
Plugin: core
Scripting name: producer_consumer_for_each
Full name: utility.producer_consumer_for_each
Internal name: producer_consumer_for_each
License: None
Changelog
- Version 0.0.0: Initial release.