YPipeBase<T>
public class YPipe<T> extends java.lang.Object implements YPipeBase<T>
private java.util.concurrent.atomic.AtomicInteger
c
private int
f
private YQueue<T>
queue
r
w
YPipe(int qsize)
boolean
checkRead()
flush()
T
probe()
read()
unwrite()
void
write(T value, boolean incomplete)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
private final YQueue<T> queue
private int w
private int r
private int f
private final java.util.concurrent.atomic.AtomicInteger c
public YPipe(int qsize)
public void write(T value, boolean incomplete)
write
public T unwrite()
unwrite
public boolean flush()
flush
public boolean checkRead()
checkRead
public T read()
read
public T probe()
probe