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)
Object	get(String taskName)
long	getDelay(String taskName, TimeUnit unit)
int	getDurability()
String	getName()
NodeEngine	getNodeEngine()
ScheduledTaskStatistics	getStatistics(String taskName)
Collection<ScheduledTaskDescriptor>	getTasks()
boolean	isCancelled(String taskName)
boolean	isDone(String taskName)
ScheduledTaskHandler	offprintHandler(String taskName)
protected void	publishTaskState(String taskName, Map stateSnapshot, ScheduledTaskStatisticsImpl statsSnapshot) State is published after every run.
ScheduledFuture	schedule(TaskDefinition definition)
boolean	shouldParkGetResult(String taskName)
void	stash(TaskDefinition definition)
void	syncState(String taskName, Map newState, ScheduledTaskStatisticsImpl stats)
void	unstash(String taskName)

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)
               throws ExecutionException,
                      InterruptedException

Throws:

ExecutionException

InterruptedException

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)
                    throws ExecutionException,
                           InterruptedException

Throws:

ExecutionException

InterruptedException

isDone

public boolean isDone(String taskName)
               throws ExecutionException,
                      InterruptedException

Throws:

ExecutionException

InterruptedException

destroy

public void destroy()

dispose

public void dispose(String taskName)
             throws ExecutionException,
                    InterruptedException

Throws:

ExecutionException

InterruptedException

stash

public void stash(TaskDefinition definition)

unstash

public void unstash(String taskName)

getTasks

public Collection<ScheduledTaskDescriptor> getTasks()

syncState

public void syncState(String taskName,
                      Map newState,
                      ScheduledTaskStatisticsImpl stats)
               throws ExecutionException,
                      InterruptedException

Throws:

ExecutionException

InterruptedException

shouldParkGetResult

public boolean shouldParkGetResult(String taskName)
                            throws ExecutionException,
                                   InterruptedException

Throws:

ExecutionException

InterruptedException

getDurability

public int getDurability()

getName

public String getName()

getNodeEngine

public NodeEngine getNodeEngine()

offprintHandler

public ScheduledTaskHandler offprintHandler(String taskName)

publishTaskState

protected void publishTaskState(String taskName,
                                Map stateSnapshot,
                                ScheduledTaskStatisticsImpl statsSnapshot)

State is published after every run. When replicas get promoted, they start of, with the latest state see TaskRunner#initOnce()

createInvocationBuilder

protected InvocationBuilder createInvocationBuilder(Operation op)