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.
|
Modifier and Type | Field and Description |
---|---|
private static PoisonPill |
PoisonPill.immediateInstance |
private static PoisonPill |
PoisonPill.ourInstance |
Modifier and Type | Method and Description |
---|---|
static PoisonPill |
PoisonPill.getImmediateInstance()
Retrieves an immediate poison pill instance
|
static PoisonPill |
PoisonPill.getInstance()
Retrieves a non-immediate poison pill instance
|