Package net.thevpc.naru.impl.engine.scheduler

Class NaruTaskInboxImpl

java.lang.Object

net.thevpc.naru.impl.engine.scheduler.NaruTaskInboxImpl

All Implemented Interfaces:

NaruTaskInbox, net.thevpc.nuts.elem.NToElement

public class NaruTaskInboxImpl
extends Object
implements NaruTaskInbox

Constructor Summary

Constructors

Constructor	Description
NaruTaskInboxImpl(NaruTask task)

Method Summary

Modifier and Type	Method	Description
NaruEvent	consume(long seq)
List<NaruEvent>	drainMatching(NaruEventFilter filter)
boolean	isEmpty()
void	load(net.thevpc.nuts.elem.NObjectElement inbox1)
NaruEvent	peek(NaruEventFilter filter)
void	push(long seq)
int	size()
net.thevpc.nuts.elem.NElement	toElement()
long	watermark()

Methods inherited from class java.lang.Object

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

Constructor Details

NaruTaskInboxImpl

public NaruTaskInboxImpl(NaruTask task)

Method Details

size

public int size()

Specified by:

size in interface NaruTaskInbox

isEmpty

public boolean isEmpty()

push

public void push(long seq)

Specified by:

push in interface NaruTaskInbox

peek

public NaruEvent peek(NaruEventFilter filter)

Specified by:

peek in interface NaruTaskInbox

consume

public NaruEvent consume(long seq)

Specified by:

consume in interface NaruTaskInbox

drainMatching

public List<NaruEvent> drainMatching(NaruEventFilter filter)

Specified by:

drainMatching in interface NaruTaskInbox

watermark

public long watermark()

Specified by:

watermark in interface NaruTaskInbox

toElement

public net.thevpc.nuts.elem.NElement toElement()

Specified by:

toElement in interface net.thevpc.nuts.elem.NToElement

load

public void load(net.thevpc.nuts.elem.NObjectElement inbox1)