class VardanERSAP.CrateProducer
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
(package private) long |
getSequence
Current spot in ring from which an item was claimed.
|
(package private) int |
streamNum
Is this stream 0 or stream 1?
|
Constructor and Description |
---|
CrateProducer(int streamNumber) |
Modifier and Type | Method and Description |
---|---|
java.nio.ByteBuffer |
get()
Get the next available item in ring buffer for writing/reading data.
|
void |
publish()
Used to tell the consumer that the ring buffer item gotten with this producer's
last call to
get() (and all previously gotten items) is ready for consumption. |
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
int streamNum
long getSequence
public java.nio.ByteBuffer get() throws java.lang.InterruptedException
java.lang.InterruptedException
- if thread interrupted.public void publish()
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread