org.tapchain.core

Class DelayedSyncQueue<T extends java.util.concurrent.Delayed>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.DelayQueue<T>

org.tapchain.core.DelayedSyncQueue<T>

All Implemented Interfaces:

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

public class DelayedSyncQueue<T extends java.util.concurrent.Delayed>
extends java.util.concurrent.DelayQueue<T>
implements IAxon<T>

Created by hiro on 2015/06/03.

Nested Class Summary

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

IAxon.AxonException

Constructor Summary

Constructors

Constructor and Description
DelayedSyncQueue()
DelayedSyncQueue(int _size)

Method Summary

Methods

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

Methods inherited from class java.util.concurrent.DelayQueue

add, clear, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, take, toArray, toArray

Methods inherited from class java.util.AbstractQueue

addAll, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, 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.concurrent.BlockingQueue

contains

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAll

Constructor Detail

DelayedSyncQueue

public DelayedSyncQueue()

DelayedSyncQueue

public DelayedSyncQueue(int _size)

Method Detail

reset

public DelayedSyncQueue<T> reset()

Specified by:

reset in interface IAxon<T extends java.util.concurrent.Delayed>

sync_push

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

Specified by:

sync_push in interface IAxon<T extends java.util.concurrent.Delayed>

Throws:

java.lang.InterruptedException

sync_pop

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

Specified by:

sync_pop in interface IAxon<T extends java.util.concurrent.Delayed>

Throws:

java.lang.InterruptedException

IAxon.AxonException

async_push

public boolean async_push(T i)

Specified by:

async_push in interface IAxon<T extends java.util.concurrent.Delayed>

apop

public T apop()

CloseWhenEmpty

public void CloseWhenEmpty()

Specified by:

CloseWhenEmpty in interface IAxon<T extends java.util.concurrent.Delayed>

CloseForced

public void CloseForced()

Specified by:

CloseForced in interface IAxon<T extends java.util.concurrent.Delayed>

isClosed

public boolean isClosed()

Specified by:

isClosed in interface IAxon<T extends java.util.concurrent.Delayed>

getCache

public T getCache()

Specified by:

getCache in interface IAxon<T extends java.util.concurrent.Delayed>

sync_peek

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

Specified by:

sync_peek in interface IAxon<T extends java.util.concurrent.Delayed>

Throws:

java.lang.InterruptedException

IAxon.AxonException

setSize

public boolean setSize(int a)

Specified by:

setSize in interface IAxon<T extends java.util.concurrent.Delayed>