| Package | Description |
|---|---|
| groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
| groovyx.gpars.dataflow.expression | |
| groovyx.gpars.dataflow.impl | |
| groovyx.gpars.dataflow.stream |
| Class and Description |
|---|
| DataflowChannelEventListenerManager |
| DataflowChannelEventOrchestrator
Groups the listener-related functionality shared by dataflow channels
|
| ResizeableCountDownLatch
CountDownLatch with the ability to change the number of waiting parties
|
| SelectBase
The implementation of the core for all selects.
|
| Class and Description |
|---|
| BindErrorListenerManager |
| DataflowChannelEventListenerManager |
| DataflowChannelEventOrchestrator
Groups the listener-related functionality shared by dataflow channels
|
| Class and Description |
|---|
| BindErrorDistributor
Fires requested events
|
| BindErrorListenerManager |
| DataflowChannelEventDistributor |
| DataflowChannelEventListenerManager |
| ResizeableCountDownLatch.Sync
Synchronization control For CountDownLatch.
|
| SelectRequest
Represents a request for value from a select.
|
| Class and Description |
|---|
| DataflowChannelEventListenerManager |
| DataflowChannelEventOrchestrator
Groups the listener-related functionality shared by dataflow channels
|