public class ScheduledExecutorContainer extends Object
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,ScheduledTaskDescriptor> |
tasks |
protected final ConcurrentMap<String,ScheduledTaskDescriptor> tasks
public ScheduledFuture schedule(TaskDefinition definition)
public boolean cancel(String taskName)
public boolean has(String taskName)
public Object get(String taskName) throws ExecutionException, InterruptedException
public ScheduledTaskStatistics getStatistics(String taskName)
public boolean isCancelled(String taskName)
public boolean isDone(String taskName)
public void destroy()
public void dispose(String taskName)
public void enqueueSuspended(TaskDefinition definition)
public void enqueueSuspended(ScheduledTaskDescriptor descriptor, boolean force)
public Collection<ScheduledTaskDescriptor> getTasks()
public void syncState(String taskName, Map newState, ScheduledTaskStatisticsImpl stats, ScheduledTaskResult resolution)
public boolean shouldParkGetResult(String taskName)
public int getDurability()
public String getName()
public int getPartitionId()
public NodeEngine getNodeEngine()
public ScheduledTaskHandler offprintHandler(String taskName)
public void promoteSuspended()
public ScheduledTaskDescriptor merge(SplitBrainMergeTypes.ScheduledExecutorMergeTypes mergingEntry, SplitBrainMergePolicy<ScheduledTaskDescriptor,SplitBrainMergeTypes.ScheduledExecutorMergeTypes> mergePolicy)
SplitBrainMergeTypes.ScheduledExecutorMergeTypes
via the given SplitBrainMergePolicy
.mergingEntry
- the SplitBrainMergeTypes.ScheduledExecutorMergeTypes
instance to mergemergePolicy
- the SplitBrainMergePolicy
instance to applyScheduledTaskDescriptor
if merge is applied, otherwise null
protected InvocationBuilder createInvocationBuilder(Operation op)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.