com.espertech.esper.epl.named

Class NamedWindowConsumerLatchWait

java.lang.Object

com.espertech.esper.epl.named.NamedWindowConsumerLatch

com.espertech.esper.epl.named.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 and Description
NamedWindowConsumerLatchWait(NamedWindowConsumerLatchFactory factory)
NamedWindowConsumerLatchWait(NamedWindowDeltaData deltaData, Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> dispatchTo, NamedWindowConsumerLatchFactory factory, NamedWindowConsumerLatchWait earlier)

Method Summary

Modifier and Type	Method and 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.
Thread	getCurrentThread()
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.epl.named.NamedWindowConsumerLatch

getDeltaData, getDispatchTo

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedWindowConsumerLatchWait

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

NamedWindowConsumerLatchWait

public NamedWindowConsumerLatchWait(NamedWindowConsumerLatchFactory factory)

Method Detail

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

getCurrentThread

public Thread getCurrentThread()

Specified by:

getCurrentThread 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