Package org.ores.async

Class NeoQueue<T,V>

java.lang.Object

org.ores.async.NeoQueue<T,V>

public class NeoQueue<T,V>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NeoQueue.AsyncCallback<T>
static interface	NeoQueue.IAsyncCb
static interface	NeoQueue.IAsyncErrFirstCb<T>
static interface	NeoQueue.ICallbacks<T>
static interface	NeoQueue.ITaskHandler<T,V>
static class	NeoQueue.Task<T,V>

Constructor Summary

Constructors

Constructor	Description
NeoQueue(java.lang.Integer concurrency, NeoQueue.ITaskHandler<T,V> h)
NeoQueue(NeoQueue.ITaskHandler<T,V> h)

Method Summary

Modifier and Type	Method	Description
java.lang.Integer	getConcurrency()
java.util.List<NeoQueue.IAsyncCb>	getOnDrainCbs()
java.util.List<NeoQueue.IAsyncCb>	getOnSaturatedCbs()
java.util.List<NeoQueue.IAsyncCb>	getOnUnsaturatedCbs()
boolean	isDrained()
static void	main()
void	nudge()
void	onDrain(NeoQueue.IAsyncCb cb)
void	onSaturated(NeoQueue.IAsyncCb cb)
void	onUnsaturated(NeoQueue.IAsyncCb cb)
void	pause()
void	push(NeoQueue.Task<T,V> t)
void	push(NeoQueue.Task<T,V> t, NeoQueue.IAsyncErrFirstCb<V> cb)
void	resume()
java.lang.Integer	setConcurrency(java.lang.Integer v)
void	setDrained(boolean drained)
void	unshift(NeoQueue.Task<T,V> t)

Methods inherited from class java.lang.Object

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

Constructor Detail

NeoQueue

public NeoQueue(java.lang.Integer concurrency,
                NeoQueue.ITaskHandler<T,V> h)

NeoQueue

public NeoQueue(NeoQueue.ITaskHandler<T,V> h)

Method Detail

main

public static void main()

getConcurrency

public java.lang.Integer getConcurrency()

isDrained

public boolean isDrained()

getOnDrainCbs

public java.util.List<NeoQueue.IAsyncCb> getOnDrainCbs()

setDrained

public void setDrained(boolean drained)

getOnSaturatedCbs

public java.util.List<NeoQueue.IAsyncCb> getOnSaturatedCbs()

getOnUnsaturatedCbs

public java.util.List<NeoQueue.IAsyncCb> getOnUnsaturatedCbs()

setConcurrency

public java.lang.Integer setConcurrency(java.lang.Integer v)

nudge

public void nudge()

push

public void push(NeoQueue.Task<T,V> t)

push

public void push(NeoQueue.Task<T,V> t,
                 NeoQueue.IAsyncErrFirstCb<V> cb)

onDrain

public void onDrain(NeoQueue.IAsyncCb cb)

onSaturated

public void onSaturated(NeoQueue.IAsyncCb cb)

onUnsaturated

public void onUnsaturated(NeoQueue.IAsyncCb cb)

unshift

public void unshift(NeoQueue.Task<T,V> t)

pause

public void pause()

resume

public void resume()