public class ProxyChannelFactory extends Object
Constructor and Description |
---|
ProxyChannelFactory() |
Modifier and Type | Method and Description |
---|---|
static <E> ProxyChannel<E> |
createMpscProxy(int capacity,
Class<E> iFace,
WaitStrategy waitStrategy)
Create a default multi producer single consumer (MPSC) proxy channel.
|
static <E> ProxyChannel<E> |
createProxy(int capacity,
Class<E> iFace,
WaitStrategy waitStrategy,
Class<? extends ProxyChannelRingBuffer> backendType)
Create a proxy channel using a user supplied back end.
|
static <E> ProxyChannel<E> |
createSpscProxy(int capacity,
Class<E> iFace,
WaitStrategy waitStrategy)
Create a default single producer single consumer (SPSC) proxy channel.
|
static long |
writeAcquireWithWaitStrategy(ProxyChannelRingBuffer channelBackend,
WaitStrategy waitStrategy) |
public static long writeAcquireWithWaitStrategy(ProxyChannelRingBuffer channelBackend, WaitStrategy waitStrategy)
public static <E> ProxyChannel<E> createSpscProxy(int capacity, Class<E> iFace, WaitStrategy waitStrategy)
capacity
- The minimum capacity for unprocessed invocations the channel
should supportiFace
- Interface the proxy must implementwaitStrategy
- A wait strategy to be invoked when the backing data structure
is fullpublic static <E> ProxyChannel<E> createMpscProxy(int capacity, Class<E> iFace, WaitStrategy waitStrategy)
capacity
- The minimum capacity for unprocessed invocations the channel
should supportiFace
- Interface the proxy must implementwaitStrategy
- A wait strategy to be invoked when the backing data structure
is fullpublic static <E> ProxyChannel<E> createProxy(int capacity, Class<E> iFace, WaitStrategy waitStrategy, Class<? extends ProxyChannelRingBuffer> backendType)
capacity
- The minimum capacity for unprocessed invocations the channel
should supportiFace
- Interface the proxy must implementwaitStrategy
- A wait strategy to be invoked when the backing data structure
is fullbackendType
- The back end type, the proxy will inherit from this channel
type. The back end type must define a constructor with signature:
(int capacity, int primitiveMessageSize, int referenceMessageSize)
Copyright © 2013–2020. All rights reserved.