/** * Copyright 2013 JogAmp Community. All rights reserved. * * Redistribution and use in source and binary forms, with or without modification, are * permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright notice, this list of * conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright notice, this list * of conditions and the following disclaimer in the documentation and/or other materials * provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY JogAmp Community ``AS IS'' AND ANY EXPRESS OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL JogAmp Community OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * * The views and conclusions contained in the software and documentation are those of the * authors and should not be interpreted as representing official policies, either expressed * or implied, of JogAmp Community. */ package com.jogamp.common.util; import java.io.PrintStream; /** * Ring buffer interface, a.k.a circular buffer. *
* Caller can chose whether to block until get / put is able to proceed or not. *
** Caller can chose whether to pass an empty array and clear references at get, * or using a preset array for circular access of same objects. *
** Synchronization and hence thread safety details belong to the implementation. *
*/ public interface Ringbuffer* The layout and size of the internal array is implementation dependent. *
** Users shall not modify or rely on the returned array. *
* @deprecated This method should not be required */ public T[] getInternalArray(); /** Returns the net capacity of this ring buffer. */ public int capacity(); /** * Resets the read and write position according to an empty ring buffer * and set all ring buffer slots tonull
.
*
* {@link #isEmpty()} will return true
after calling this method.
*
copyFrom
.
*
* Array's copyFrom
elements will be copied into the internal array,
* hence it's length must be equal to {@link #capacity()}.
*
copyFrom
is null
.
* @throws IllegalArgumentException if copyFrom
's length is different from {@link #capacity()}.
*/
public void resetFull(T[] copyFrom) throws IllegalArgumentException;
/** Returns the number of elements in this ring buffer. */
public int size();
/** Returns the number of free slots available to put. */
public int getFreeSlots();
/** Returns true if this ring buffer is empty, otherwise false. */
public boolean isEmpty();
/** Returns true if this ring buffer is full, otherwise false. */
public boolean isFull();
/**
* Dequeues the oldest enqueued element if available, otherwise null.
*
* The returned ring buffer slot will be set to null
to release the reference
* and move ownership to the caller.
*
* Method is non blocking and returns immediately;. *
* @return the oldest put element if available, otherwise null. */ public T get(); /** * Dequeues the oldest enqueued element. *
* The returned ring buffer slot will be set to null
to release the reference
* and move ownership to the caller.
*
* Methods blocks until an element becomes available via put. *
* @return the oldest put element * @throws InterruptedException */ public T getBlocking() throws InterruptedException; /** * Peeks the next element at the read position w/o modifying pointer, nor blocking. * @returnnull
if empty, otherwise the element which would be read next.
*/
public T peek();
/**
* Peeks the next element at the read position w/o modifying pointer, but w/ blocking.
* @return null
if empty, otherwise the element which would be read next.
*/
public T peekBlocking() throws InterruptedException;
/**
* Enqueues the given element.
* * Returns true if successful, otherwise false in case buffer is full. *
** Method is non blocking and returns immediately;. *
*/ public boolean put(T e); /** * Enqueues the given element. ** Method blocks until a free slot becomes available via get. *
* @throws InterruptedException */ public void putBlocking(T e) throws InterruptedException; /** * Enqueues the same element at it's write position, if not full. ** Returns true if successful, otherwise false in case buffer is full. *
*
* If blocking
is true, method blocks until a free slot becomes available via get.
*
count
free slots become available.
* @throws InterruptedException
*/
public void waitForFreeSlots(int count) throws InterruptedException;
/**
* Grows an empty ring buffer, increasing it's capacity about the amount.
* * Growing an empty ring buffer increases it's size about the amount, i.e. renders it not empty. * The new elements are inserted at the read position, able to be read out via {@link #get()} etc. *
* * @param newElements array of new full elements the empty buffer shall grow about. * @throws IllegalStateException if buffer is not empty * @throws IllegalArgumentException if newElements is null */ public void growEmptyBuffer(T[] newElements) throws IllegalStateException, IllegalArgumentException; /** * Grows a full ring buffer, increasing it's capacity about the amount. *
* Growing a full ring buffer leaves the size intact, i.e. renders it not full.
* New null
elements are inserted at the write position, able to be written to via {@link #put(Object)} etc.
*