Package org.apache.cassandra.concurrent

Interface ScheduledExecutorPlus

All Superinterfaces:

Executor, ExecutorPlus, ExecutorService, ResizableThreadPool, ScheduledExecutorService

All Known Implementing Classes:

ScheduledThreadPoolExecutorPlus

public interface ScheduledExecutorPlus
extends ExecutorPlus, ScheduledExecutorService

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.concurrent.ExecutorPlus

ExecutorPlus.MaximumPoolSizeListener

Method Summary

Modifier and Type	Method	Description
ScheduledFuture<?>	scheduleAt(Runnable run, long deadline)	Schedule a timeout action.
ScheduledFuture<?>	scheduleSelfRecurring(Runnable run, long delay, TimeUnit units)	Schedule an action that is recurring but self-administered.
ScheduledFuture<?>	scheduleTimeoutAt(Runnable run, long deadline)	Schedule a timeout action.
ScheduledFuture<?>	scheduleTimeoutWithDelay(Runnable run, long delay, TimeUnit units)	Schedule a timeout action.

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface org.apache.cassandra.concurrent.ExecutorPlus

execute, inExecutor, invokeAll, invokeAll, invokeAny, invokeAny, maybeExecuteImmediately, submit, submit, submit, submit, submit, submit

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

Methods inherited from interface org.apache.cassandra.concurrent.ResizableThreadPool

getActiveTaskCount, getCompletedTaskCount, getCorePoolSize, getMaximumPoolSize, getMaxTasksQueued, getPendingTaskCount, oldestTaskQueueTime, setCorePoolSize, setMaximumPoolSize

Methods inherited from interface java.util.concurrent.ScheduledExecutorService

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Method Details

scheduleSelfRecurring

ScheduledFuture<?> scheduleSelfRecurring(Runnable run,
 long delay,
 TimeUnit units)

Schedule an action that is recurring but self-administered.

scheduleAt

ScheduledFuture<?> scheduleAt(Runnable run,
 long deadline)

Schedule a timeout action. This method is primarily used by the Simulator to modify its scheduling behaviour with respect to this operation.

scheduleTimeoutAt

ScheduledFuture<?> scheduleTimeoutAt(Runnable run,
 long deadline)

Schedule a timeout action. This method is primarily used by the Simulator to modify its scheduling behaviour with respect to this operation.

scheduleTimeoutWithDelay

ScheduledFuture<?> scheduleTimeoutWithDelay(Runnable run,
 long delay,
 TimeUnit units)

Schedule a timeout action. This method is primarily used by the Simulator to modify its scheduling behaviour with respect to this operation.