public class DemoProxyResult extends SpscOffHeapFixedSizeRingBuffer implements ProxyChannel<Demo1>, Demo1
EOF
bufferAddress, consumerIndexAddress, HEADER_SIZE, mask, MESSAGE_INDICATOR_SIZE, messageSize, producerIndexAddress, READ_ACQUIRE_INDICATOR, READ_RELEASE_INDICATOR, WRITE_ACQUIRE_INDICATOR, WRITE_RELEASE_INDICATOR
Constructor and Description |
---|
DemoProxyResult(int capacity) |
Modifier and Type | Method and Description |
---|---|
void |
call1(int x,
int y) |
void |
call2(float x,
double y,
boolean z) |
void |
call3() |
int |
process(Demo1 impl,
int limit) |
Demo1 |
proxy() |
Demo1 |
proxyInstance(Demo1 impl) |
getLookaheadStep, readAcquire, readRelease, writeAcquire, writeRelease, writeRelease
capacity, getRequiredBufferSize, isEmpty, isReadReleased, lpConsumerIndex, lpProducerIndex, lvConsumerIndex, lvProducerIndex, offsetForIndex, offsetForIndex, readAcquireState, readReleaseState, size, soConsumerIndex, soProducerIndex, writeAcquireState, writeReleaseState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
capacity, isEmpty, size
public Demo1 proxyInstance(Demo1 impl)
proxyInstance
in interface ProxyChannel<Demo1>
public Demo1 proxy()
proxy
in interface ProxyChannel<Demo1>
public int process(Demo1 impl, int limit)
process
in interface ProxyChannel<Demo1>
impl
- into which the calls are made where they are not for a proxy instancelimit
- maximum number of calls to process through