com.espertech.esper.epl.named
Class NamedWindowConsumerLatchFactory

java.lang.Object
  com.espertech.esper.epl.named.NamedWindowConsumerLatchFactory

public class NamedWindowConsumerLatchFactory
extends java.lang.Object

Class to hold a current latch per named window.

Field Summary

protected boolean	enabled
protected long	msecWait
protected java.lang.String	name
protected TimeSourceService	timeSourceService
protected boolean	useSpin

Constructor Summary

NamedWindowConsumerLatchFactory(java.lang.String name, boolean enabled, long msecWait, ConfigurationEngineDefaults.Threading.Locking locking, TimeSourceService timeSourceService, boolean initializeNow)
Ctor.

Method Summary

long	getMsecWait()
java.lang.String	getName()
TimeSourceService	getTimeSourceService()
NamedWindowConsumerLatch	newLatch(NamedWindowDeltaData delta, java.util.Map<EPStatementAgentInstanceHandle,java.util.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 java.lang.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(java.lang.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

Method Detail

newLatch

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

Returns a new latch.

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

Returns:

latch

getTimeSourceService

public TimeSourceService getTimeSourceService()

getName

public java.lang.String getName()

getMsecWait

public long getMsecWait()