Package org.apache.cassandra.db.compaction

Class CompactionManager.ValidationExecutor

java.lang.Object

org.apache.cassandra.concurrent.WrappedExecutorPlus

org.apache.cassandra.db.compaction.CompactionManager.ValidationExecutor

All Implemented Interfaces:

Executor, ExecutorService, ExecutorPlus, ResizableThreadPool

Enclosing class:

CompactionManager

public static class CompactionManager.ValidationExecutor
extends WrappedExecutorPlus

Nested Class Summary

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

ExecutorPlus.MaximumPoolSizeListener

Field Summary

Fields inherited from class org.apache.cassandra.concurrent.WrappedExecutorPlus

executor

Constructor Summary

Constructors

Constructor	Description
ValidationExecutor()

Method Summary

Modifier and Type	Method	Description
void	adjustPoolSize()
void	execute(Runnable command)
Future<?>	submit(Runnable task)	Overrides ExecutorService.submit(Runnable) to return a Cassandra Future
<T> Future<T>	submit(Runnable task, T result)	Overrides ExecutorService.submit(Runnable, Object) to return a Cassandra Future
<T> Future<T>	submit(Callable<T> task)	Overrides ExecutorService.submit(Callable) to return a Cassandra Future
Future<Void>	submitIfRunning(Runnable task, String name)
<T> Future<T>	submitIfRunning(Callable<T> task, String name)	Submit the task but only if the executor has not been shutdown.If the executor has been shutdown, or in case of a rejected execution exception return a cancelled future.

Methods inherited from class org.apache.cassandra.concurrent.WrappedExecutorPlus

awaitTermination, execute, getActiveTaskCount, getCompletedTaskCount, getCorePoolSize, getMaximumPoolSize, getMaxTasksQueued, getPendingTaskCount, inExecutor, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, maybeExecuteImmediately, setCorePoolSize, setMaximumPoolSize, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class java.lang.Object

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

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

oldestTaskQueueTime

Constructor Details

ValidationExecutor

public ValidationExecutor()

Method Details

adjustPoolSize

public void adjustPoolSize()

submitIfRunning

public Future<Void> submitIfRunning(Runnable task,
 String name)

submitIfRunning

public <T> Future<T> submitIfRunning(Callable<T> task,
 String name)

Submit the task but only if the executor has not been shutdown.If the executor has been shutdown, or in case of a rejected execution exception return a cancelled future.

Parameters:

task - - the task to submit

name - - the task name to use in log messages

Returns:

the future that will deliver the task result, or a future that has already been cancelled if the task could not be submitted.

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Overrides:

execute in class WrappedExecutorPlus

submit

public <T> Future<T> submit(Callable<T> task)

Description copied from interface: ExecutorPlus

Overrides ExecutorService.submit(Callable) to return a Cassandra Future

Specified by:

submit in interface ExecutorPlus

Specified by:

submit in interface ExecutorService

Overrides:

submit in class WrappedExecutorPlus

submit

public <T> Future<T> submit(Runnable task,
 T result)

Description copied from interface: ExecutorPlus

Overrides ExecutorService.submit(Runnable, Object) to return a Cassandra Future

Specified by:

submit in interface ExecutorPlus

Specified by:

submit in interface ExecutorService

Overrides:

submit in class WrappedExecutorPlus

submit

public Future<?> submit(Runnable task)

Description copied from interface: ExecutorPlus

Overrides ExecutorService.submit(Runnable) to return a Cassandra Future

Specified by:

submit in interface ExecutorPlus

Specified by:

submit in interface ExecutorService

Overrides:

submit in class WrappedExecutorPlus