Constructor and Description |
---|
SpscChannel(ByteBuffer buffer,
int requestedCapacity,
Class<E> type)
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
|
Modifier and Type | Method and Description |
---|---|
ChannelConsumer |
consumer(ChannelReceiver<E> receiver) |
boolean |
isEmpty() |
int |
maximumCapacity() |
ChannelProducer<E> |
producer() |
int |
requestedCapacity() |
int |
size()
Get the number of elements in the queue.
|
public SpscChannel(ByteBuffer buffer, int requestedCapacity, Class<E> type)
buffer
- requestedCapacity
- public ChannelConsumer consumer(ChannelReceiver<E> receiver)
public ChannelProducer<E> producer()
public int size()
Channel
public int maximumCapacity()
maximumCapacity
in interface Channel<E>
public int requestedCapacity()
requestedCapacity
in interface Channel<E>
Copyright © 2013-2016. All Rights Reserved.