org.tapchain.core

Class SyncObject<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.SynchronousQueue<T>

org.tapchain.core.SyncObject<T>

All Implemented Interfaces:

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

public class SyncObject<T>
extends java.util.concurrent.SynchronousQueue<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
SyncObject()

Method Summary

Methods

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

Methods inherited from class java.util.concurrent.SynchronousQueue

clear, contains, containsAll, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, retainAll, take, toArray, toArray

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

add

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, equals, hashCode

Constructor Detail

SyncObject

public SyncObject()

Method Detail

sync_push

public boolean sync_push(T i)

Specified by:

sync_push in interface IAxon<T>

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

sync_peek

public T sync_peek()

Specified by:

sync_peek in interface IAxon<T>

async_push

public boolean async_push(T i)

Specified by:

async_push in interface IAxon<T>

size

public int size()

Specified by:

size in interface java.util.Collection<T>

Specified by:

size in interface IAxon<T>

Overrides:

size in class java.util.concurrent.SynchronousQueue<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<T>

Specified by:

isEmpty in interface IAxon<T>

Overrides:

isEmpty in class java.util.concurrent.SynchronousQueue<T>

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>

reset

public IAxon<T> reset()

Specified by:

reset in interface IAxon<T>

getCache

public T getCache()

Specified by:

getCache in interface IAxon<T>

setSize

public boolean setSize(int a)

Specified by:

setSize in interface IAxon<T>