Package com.espertech.esper.common.internal.epl.namedwindow.consume

Class NamedWindowConsumerLatchWait

java.lang.Object

com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerLatch

com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerLatchWait

public class NamedWindowConsumerLatchWait
extends NamedWindowConsumerLatch

A suspend-and-notify implementation of a latch for use in guaranteeing delivery between a named window delta result and consumable by another statement.

Constructor Summary

Constructors

Constructor	Description
NamedWindowConsumerLatchWait(NamedWindowConsumerLatchFactory factory)
NamedWindowConsumerLatchWait(NamedWindowDeltaData deltaData, Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo, NamedWindowConsumerLatchFactory factory, NamedWindowConsumerLatchWait earlier)

Method Summary

Modifier and Type	Method	Description
void	await()	Blcking call that returns only when the earlier latch completed.
void	done()	Called to indicate that the latch completed and a later latch can start.
NamedWindowConsumerLatchWait	getEarlier()
boolean	isCompleted()	Returns true if the dispatch completed for this future.
void	setLater(NamedWindowConsumerLatchWait later)	Hand a later latch to use for indicating completion via notify.

Methods inherited from class com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerLatch

getDeltaData, getDispatchTo

Methods inherited from class java.lang.Object

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

Constructor Details

NamedWindowConsumerLatchWait

public NamedWindowConsumerLatchWait(NamedWindowDeltaData deltaData,
 Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo,
 NamedWindowConsumerLatchFactory factory,
 NamedWindowConsumerLatchWait earlier)

NamedWindowConsumerLatchWait

public NamedWindowConsumerLatchWait(NamedWindowConsumerLatchFactory factory)

Method Details

getEarlier

public NamedWindowConsumerLatchWait getEarlier()

Specified by:

getEarlier in class NamedWindowConsumerLatch

isCompleted

public boolean isCompleted()

Returns true if the dispatch completed for this future.

Returns:

true for completed, false if not

setLater

public void setLater(NamedWindowConsumerLatchWait later)

Hand a later latch to use for indicating completion via notify.

Parameters:

later - is the later latch

await

public void await()

Blcking call that returns only when the earlier latch completed.

Specified by:

await in class NamedWindowConsumerLatch

done

public void done()

Called to indicate that the latch completed and a later latch can start.

Specified by:

done in class NamedWindowConsumerLatch