org.jlab.coda.emu.test

Class VardanERSAP.OutputRingConsumer

java.lang.Object

java.lang.Thread

org.jlab.coda.emu.test.VardanERSAP.OutputRingConsumer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

VardanERSAP

class VardanERSAP.OutputRingConsumer
extends java.lang.Thread

Thread to consume from output ring.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	getOutSequence Current spot in output ring from which an item was claimed.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
OutputRingConsumer()

Method Summary

Modifier and Type	Method and Description
java.nio.ByteBuffer	get() Get the next available item from outupt ring buffer.
void	put() This "consumer" is also a producer for the output ring.
void	run()

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

getOutSequence

long getOutSequence

Current spot in output ring from which an item was claimed.

Constructor Detail

OutputRingConsumer

OutputRingConsumer()

Method Detail

get

public java.nio.ByteBuffer get()
                        throws java.lang.InterruptedException

Get the next available item from outupt ring buffer. Do NOT call this multiple times in a row! Be sure to call "put" before calling this again.

Returns:

next available item in ring buffer.

Throws:

java.lang.InterruptedException - if thread interrupted.

put

public void put()

This "consumer" is also a producer for the output ring. So get items from the output ring and fill them with items claimed from the input rings.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread