Package | Description |
---|---|
groovyx.gpars.dataflow.operator |
This package holds classes representing operators and channels necessary for full dataflow concurrency.
|
Modifier and Type | Class and Description |
---|---|
class |
CountingPoisonPill
Represents a non-immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
|
class |
ImmediateCountingPoisonPill
Represents an immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
|
class |
PoisonPill
Represents the poison for dataflow operators.
|