com.espertech.esper.schedule

Class SchedulingMgmtServiceImpl

java.lang.Object

com.espertech.esper.schedule.SchedulingMgmtServiceImpl

All Implemented Interfaces:

SchedulingMgmtService

public final class SchedulingMgmtServiceImpl
extends Object
implements SchedulingMgmtService

Implements the schedule service by simply keeping a sorted set of long millisecond values and a set of handles for each.

Synchronized since statement creation and event evaluation by multiple (event send) threads can lead to callbacks added/removed asynchronously.

Constructor Summary

Constructors

Constructor and Description
SchedulingMgmtServiceImpl() Constructor.

Method Summary

Modifier and Type	Method and Description
ScheduleBucket	allocateBucket() Returns a bucket from which slots can be allocated for ordering concurrent callbacks.
void	destroy() Destroy the service.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulingMgmtServiceImpl

public SchedulingMgmtServiceImpl()

Constructor.

Method Detail

destroy

public void destroy()

Description copied from interface: SchedulingMgmtService

Destroy the service.

Specified by:

destroy in interface SchedulingMgmtService

allocateBucket

public ScheduleBucket allocateBucket()

Description copied from interface: SchedulingMgmtService

Returns a bucket from which slots can be allocated for ordering concurrent callbacks.

Specified by:

allocateBucket in interface SchedulingMgmtService

Returns:

bucket