net.esper.core
Class InsertIntoLatchFactory

java.lang.Object
  extended by net.esper.core.InsertIntoLatchFactory

public class InsertIntoLatchFactory
extends Object

Class to hold a current latch per statement that uses an insert-into stream (per statement and insert-into stream relationship).


Constructor Summary
InsertIntoLatchFactory(String name, long msecWait, ConfigurationEngineDefaults.Threading.Locking locking)
          Ctor.
 
Method Summary
 Object newLatch(Object payload)
          Returns a new latch.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InsertIntoLatchFactory

public InsertIntoLatchFactory(String name,
                              long msecWait,
                              ConfigurationEngineDefaults.Threading.Locking locking)
Ctor.

Parameters:
name - the factory name
msecWait - the number of milliseconds latches will await maximually
locking - the blocking strategy to employ
Method Detail

newLatch

public Object newLatch(Object payload)
Returns a new latch.

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

Parameters:
payload - is the object returned by the await.
Returns:
latch

© 2007 EsperTech Inc.
All rights reserved.
Visit us at espertech.com