org.tapchain.core

Class SyncQueue<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<T>

org.tapchain.core.SyncQueue<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Iterable<T>, java.util.Collection<T>, java.util.Queue<T>, IAxon<T>

public class SyncQueue<T>
extends java.util.concurrent.ConcurrentLinkedQueue<T>
implements IAxon<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.tapchain.core.IAxon

IAxon.AxonException

Constructor Summary

Constructors

Constructor and Description
SyncQueue()
SyncQueue(int _size)

Method Summary

Methods

Modifier and Type	Method and Description
T	apop()
T	async_peek()
boolean	async_push(T i)
void	CloseForced()
void	CloseWhenEmpty()
T	getCache()
boolean	isClosed()
SyncQueue<T>	reset()
boolean	setSize(int a)
T	sync_peek()
T	sync_pop()
boolean	sync_push(T i)

Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue

add, addAll, contains, isEmpty, iterator, offer, peek, poll, remove, size, toArray, toArray

Methods inherited from class java.util.AbstractQueue

clear, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tapchain.core.IAxon

isEmpty, size

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

clear, containsAll, equals, hashCode, removeAll, retainAll

Constructor Detail

SyncQueue

public SyncQueue()

SyncQueue

public SyncQueue(int _size)

Method Detail

reset

public SyncQueue<T> reset()

Specified by:

reset in interface IAxon<T>

sync_push

public boolean sync_push(T i)
                  throws java.lang.InterruptedException

Specified by:

sync_push in interface IAxon<T>

Throws:

java.lang.InterruptedException

sync_pop

public T sync_pop()
           throws java.lang.InterruptedException,
                  IAxon.AxonException

Specified by:

sync_pop in interface IAxon<T>

Throws:

java.lang.InterruptedException

IAxon.AxonException

async_push

public boolean async_push(T i)

Specified by:

async_push in interface IAxon<T>

apop

public T apop()

CloseWhenEmpty

public void CloseWhenEmpty()

Specified by:

CloseWhenEmpty in interface IAxon<T>

CloseForced

public void CloseForced()

Specified by:

CloseForced in interface IAxon<T>

isClosed

public boolean isClosed()

Specified by:

isClosed in interface IAxon<T>

getCache

public T getCache()

Specified by:

getCache in interface IAxon<T>

sync_peek

public T sync_peek()
            throws java.lang.InterruptedException

Specified by:

sync_peek in interface IAxon<T>

Throws:

java.lang.InterruptedException

setSize

public boolean setSize(int a)

Specified by:

setSize in interface IAxon<T>

async_peek

public T async_peek()
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException