com.espertech.esper.epl.named

Class NamedWindowConsumerLatchFactory

java.lang.Object

com.espertech.esper.epl.named.NamedWindowConsumerLatchFactory

public class NamedWindowConsumerLatchFactory
extends Object

Class to hold a current latch per named window.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

NamedWindowConsumerLatchFactory

public NamedWindowConsumerLatchFactory(String name,
                                       boolean enabled,
                                       long msecWait,
                                       ConfigurationEngineDefaults.Threading.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 Detail

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()