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

Class NamedWindowConsumerLatchSpin

java.lang.Object

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

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

public class NamedWindowConsumerLatchSpin
extends NamedWindowConsumerLatch

A spin-locking implementation of a latch for use in guaranteeing delivery between a delta stream produced by a named window and consumable by another statement.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	await()	Blocking call that returns only when the earlier latch completed.
void	done()	Called to indicate that the latch completed and a later latch can start.
NamedWindowConsumerLatchSpin	getEarlier()
boolean	isCompleted()	Returns true if the dispatch completed for this future.

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

NamedWindowConsumerLatchSpin

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

NamedWindowConsumerLatchSpin

public NamedWindowConsumerLatchSpin(NamedWindowConsumerLatchFactory factory)

Method Details

getEarlier

public NamedWindowConsumerLatchSpin 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

await

public void await()

Blocking 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