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

Class NamedWindowConsumerLatchFactory

java.lang.Object

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

public class NamedWindowConsumerLatchFactory
extends Object

Class to hold a current latch per named window.

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	enabled
protected final long	msecWait
protected final String	name
protected final TimeSourceService	timeSourceService
protected final boolean	useSpin

Constructor Summary

Constructors

Constructor	Description
NamedWindowConsumerLatchFactory(String name, boolean enabled, long msecWait, Locking locking, TimeSourceService timeSourceService, boolean initializeNow)	Ctor.

Method Summary

Modifier and Type	Method	Description
long	getMsecWait()
String	getName()
TimeSourceService	getTimeSourceService()
NamedWindowConsumerLatch	newLatch(NamedWindowDeltaData delta, Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumers)	Returns a new latch.

Methods inherited from class java.lang.Object

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

Field Details

name

protected final String name

useSpin

protected final boolean useSpin

timeSourceService

protected final TimeSourceService timeSourceService

msecWait

protected final long msecWait

enabled

protected final boolean enabled

Constructor Details

NamedWindowConsumerLatchFactory

public NamedWindowConsumerLatchFactory(String name,
 boolean enabled,
 long msecWait,
 Locking locking,
 TimeSourceService timeSourceService,
 boolean initializeNow)

Ctor.

Parameters:

name - the factory name

msecWait - the number of milliseconds latches will await maximually

locking - the blocking strategy to employ

timeSourceService - time source provider

initializeNow - for initializing

enabled - for active indicator

Method Details

newLatch

public NamedWindowConsumerLatch newLatch(NamedWindowDeltaData delta,
 Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumers)

Returns a new latch.

Need not be synchronized as there is one per statement and execution is during statement lock.

Parameters:

delta - the delta

consumers - consumers

Returns:

latch

getTimeSourceService

public TimeSourceService getTimeSourceService()

getName

public String getName()

getMsecWait

public long getMsecWait()