| Package | Description |
|---|---|
| org.jctools.channels | |
| org.jctools.channels.mpsc | |
| org.jctools.channels.proxy |
This is a prototype, not working code.
|
| org.jctools.channels.spsc |
| Class and Description |
|---|
| ChannelConsumer
The consumer is the object which controls the reading of messages from a
channel.
|
| ChannelProducer
A producer used by a single thread for writing into a channel.
|
| ChannelReceiver
The receiver interface is implemented by end users in order to receiver data from the channel.
|
| Class and Description |
|---|
| Channel
A minimal top level queue interface which allows producer/consumers access via separate interfaces.
|
| ChannelConsumer
The consumer is the object which controls the reading of messages from a
channel.
|
| ChannelProducer
A producer used by a single thread for writing into a channel.
|
| ChannelReceiver
The receiver interface is implemented by end users in order to receiver data from the channel.
|
| OffHeapFixedMessageSizeRingBuffer
Channel protocol:
- Fixed message size
- 'null' indicator in message preceding byte (potentially use same for type mapping in future)
- Use FF algorithm relying on indicator to support in place detection of next element existence
|
| Class and Description |
|---|
| WaitStrategy |
| Class and Description |
|---|
| Channel
A minimal top level queue interface which allows producer/consumers access via separate interfaces.
|
| ChannelConsumer
The consumer is the object which controls the reading of messages from a
channel.
|
| ChannelProducer
A producer used by a single thread for writing into a channel.
|
| ChannelReceiver
The receiver interface is implemented by end users in order to receiver data from the channel.
|
| OffHeapFixedMessageSizeRingBuffer
Channel protocol:
- Fixed message size
- 'null' indicator in message preceding byte (potentially use same for type mapping in future)
- Use FF algorithm relying on indicator to support in place detection of next element existence
|