Package org.globus.util
Class CircularBuffer
- java.lang.Object
-
- org.globus.util.CircularBuffer
-
public class CircularBuffer extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected Object[]bufprotected booleanclosePutprotected intcountprotected intinprotected booleaninterruptGetprotected booleaninterruptPutprotected intoutprotected intsize
-
Constructor Summary
Constructors Constructor Description CircularBuffer(int size)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclosePut()Objectget()voidinterruptBoth()voidinterruptGet()voidinterruptPut()booleanisEmpty()booleanisGetInterrupted()booleanisPutClosed()booleanisPutInterrupted()booleanput(Object o)
-
-
-
Field Detail
-
buf
protected Object[] buf
-
in
protected int in
-
out
protected int out
-
count
protected int count
-
size
protected int size
-
interruptPut
protected boolean interruptPut
-
interruptGet
protected boolean interruptGet
-
closePut
protected boolean closePut
-
-
Method Detail
-
isEmpty
public boolean isEmpty()
-
put
public boolean put(Object o) throws InterruptedException
- Throws:
InterruptedException
-
get
public Object get() throws InterruptedException
- Throws:
InterruptedException
-
closePut
public void closePut()
-
isPutClosed
public boolean isPutClosed()
-
interruptBoth
public void interruptBoth()
-
interruptGet
public void interruptGet()
-
interruptPut
public void interruptPut()
-
isGetInterrupted
public boolean isGetInterrupted()
-
isPutInterrupted
public boolean isPutInterrupted()
-
-