com.hazelcast.scheduledexecutor.impl

Class ScheduledExecutorContainer

java.lang.Object

com.hazelcast.scheduledexecutor.impl.ScheduledExecutorContainer

Direct Known Subclasses:

ScheduledExecutorMemberOwnedContainer

public class ScheduledExecutorContainer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,ScheduledTaskDescriptor>	tasks

Method Summary

Modifier and Type	Method and Description
boolean	cancel(String taskName)
protected InvocationBuilder	createInvocationBuilder(Operation op)
void	destroy()
void	dispose(String taskName)
void	enqueueSuspended(ScheduledTaskDescriptor descriptor, boolean force)
void	enqueueSuspended(TaskDefinition definition)
Object	get(String taskName)
long	getDelay(String taskName, TimeUnit unit)
int	getDurability()
String	getName()
NodeEngine	getNodeEngine()
int	getPartitionId()
ScheduledTaskStatistics	getStatistics(String taskName)
Collection<ScheduledTaskDescriptor>	getTasks()
boolean	has(String taskName)
boolean	isCancelled(String taskName)
boolean	isDone(String taskName)
protected void	log(Level level, String msg)
protected void	log(Level level, String taskName, String msg)
protected void	log(Level level, String taskName, String msg, Throwable t)
ScheduledTaskDescriptor	merge(SplitBrainMergeTypes.ScheduledExecutorMergeTypes mergingEntry, SplitBrainMergePolicy<ScheduledTaskDescriptor,SplitBrainMergeTypes.ScheduledExecutorMergeTypes> mergePolicy) Merges the given SplitBrainMergeTypes.ScheduledExecutorMergeTypes via the given SplitBrainMergePolicy.
ScheduledTaskHandler	offprintHandler(String taskName)
void	promoteSuspended()
ScheduledFuture	schedule(TaskDefinition definition)
boolean	shouldParkGetResult(String taskName)
void	syncState(String taskName, Map newState, ScheduledTaskStatisticsImpl stats, ScheduledTaskResult resolution)

Methods inherited from class java.lang.Object

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

Field Detail

tasks

protected final ConcurrentMap<String,ScheduledTaskDescriptor> tasks

Method Detail

schedule

public ScheduledFuture schedule(TaskDefinition definition)

cancel

public boolean cancel(String taskName)

has

public boolean has(String taskName)

get

public Object get(String taskName)
           throws ExecutionException,
                  InterruptedException

Throws:

ExecutionException

InterruptedException

getDelay

public long getDelay(String taskName,
                     TimeUnit unit)

getStatistics

public ScheduledTaskStatistics getStatistics(String taskName)

isCancelled

public boolean isCancelled(String taskName)

isDone

public boolean isDone(String taskName)

destroy

public void destroy()

dispose

public void dispose(String taskName)

enqueueSuspended

public void enqueueSuspended(TaskDefinition definition)

enqueueSuspended

public void enqueueSuspended(ScheduledTaskDescriptor descriptor,
                             boolean force)

getTasks

public Collection<ScheduledTaskDescriptor> getTasks()

syncState

public void syncState(String taskName,
                      Map newState,
                      ScheduledTaskStatisticsImpl stats,
                      ScheduledTaskResult resolution)

shouldParkGetResult

public boolean shouldParkGetResult(String taskName)

getDurability

public int getDurability()

getName

public String getName()

getPartitionId

public int getPartitionId()

getNodeEngine

public NodeEngine getNodeEngine()

offprintHandler

public ScheduledTaskHandler offprintHandler(String taskName)

promoteSuspended

public void promoteSuspended()

merge

public ScheduledTaskDescriptor merge(SplitBrainMergeTypes.ScheduledExecutorMergeTypes mergingEntry,
                                     SplitBrainMergePolicy<ScheduledTaskDescriptor,SplitBrainMergeTypes.ScheduledExecutorMergeTypes> mergePolicy)

Merges the given SplitBrainMergeTypes.ScheduledExecutorMergeTypes via the given SplitBrainMergePolicy.

Parameters:

mergingEntry - the SplitBrainMergeTypes.ScheduledExecutorMergeTypes instance to merge

mergePolicy - the SplitBrainMergePolicy instance to apply

Returns:

the used ScheduledTaskDescriptor if merge is applied, otherwise null

createInvocationBuilder

protected InvocationBuilder createInvocationBuilder(Operation op)

log

protected void log(Level level,
                   String msg)

log

protected void log(Level level,
                   String taskName,
                   String msg)

log

protected void log(Level level,
                   String taskName,
                   String msg,
                   Throwable t)