Package | Description |
---|---|
org.jctools.channels | |
org.jctools.channels.mpsc | |
org.jctools.channels.proxy |
This is a prototype, not working code.
|
org.jctools.channels.spsc |
Modifier and Type | Class and Description |
---|---|
class |
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
|
Modifier and Type | Class and Description |
---|---|
class |
MpscChannelConsumer<E>
Package Scoped: not part of public API.
|
class |
MpscChannelProducer<E>
Package Scoped: not part of public API.
|
class |
MpscFFLamportOffHeapFixedSizeRingBuffer
A Multi-Producer-Single-Consumer ring buffer.
|
class |
MpscOffHeapFixedSizeRingBuffer
Channel protocol:
- Fixed message size
- 'null' indicator in message preceding byte (potentially use same for type mapping in future)
- Use Vyukov MPMC like algorithm relying on indicator to support in place detection of next element existence
|
Modifier and Type | Method and Description |
---|---|
static long |
ProxyChannelFactory.writeAcquireWithWaitStrategy(ProxyChannelRingBuffer channelBackend,
WaitStrategy waitStrategy) |
Modifier and Type | Method and Description |
---|---|
static <E> ProxyChannel<E> |
ProxyChannelFactory.createProxy(int capacity,
Class<E> iFace,
WaitStrategy waitStrategy,
Class<? extends ProxyChannelRingBuffer> backendType)
Create a proxy channel using a user supplied back end.
|
Modifier and Type | Class and Description |
---|---|
class |
SpscChannelConsumer<E>
Package Scoped: not part of public API.
|
class |
SpscChannelProducer<E>
Package Scoped: not part of public API.
|
class |
SpscOffHeapFixedSizeRingBuffer
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
|
Copyright © 2013–2021. All rights reserved.