org.apache.cassandra.concurrent

Class SEPExecutor

java.lang.Object

org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService

org.apache.cassandra.concurrent.SEPExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, LocalAwareExecutorService

public class SEPExecutor
extends AbstractLocalAwareExecutorService

Field Summary

Fields

Modifier and Type	Field and Description
int	maxTasksQueued
int	maxWorkers
java.lang.String	name
protected java.util.concurrent.ConcurrentLinkedQueue<org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?>>	tasks

Method Summary

Modifier and Type	Method and Description
protected void	addTask(org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> task)
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
int	getActiveTaskCount() Returns the approximate number of threads that are actively executing tasks.
long	getCompletedTaskCount() Returns the approximate total number of tasks that have completed execution.
int	getMaximumPoolSize() Returns the maximum allowed number of threads.
int	getMaxTasksQueued()
int	getPendingTaskCount() Returns the approximate total of tasks waiting to be executed.
boolean	isShutdown()
boolean	isTerminated()
void	maybeExecuteImmediately(java.lang.Runnable command)
protected void	onCompletion()
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()

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

execute, execute, invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Detail

maxWorkers

public final int maxWorkers

name

public final java.lang.String name

maxTasksQueued

public final int maxTasksQueued

tasks

protected final java.util.concurrent.ConcurrentLinkedQueue<org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?>> tasks

Method Detail

onCompletion

protected void onCompletion()

Specified by:

onCompletion in class AbstractLocalAwareExecutorService

getMaxTasksQueued

public int getMaxTasksQueued()

addTask

protected void addTask(org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> task)

Specified by:

addTask in class AbstractLocalAwareExecutorService

maybeExecuteImmediately

public void maybeExecuteImmediately(java.lang.Runnable command)

shutdown

public void shutdown()

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getPendingTaskCount

public int getPendingTaskCount()

Description copied from interface: LocalAwareExecutorService

Returns the approximate total of tasks waiting to be executed. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation, but one that does not ever decrease across successive calls.

Returns:

the number of tasks

getCompletedTaskCount

public long getCompletedTaskCount()

Description copied from interface: LocalAwareExecutorService

Returns the approximate total number of tasks that have completed execution. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation, but one that does not ever decrease across successive calls.

Returns:

the number of tasks

getActiveTaskCount

public int getActiveTaskCount()

Description copied from interface: LocalAwareExecutorService

Returns the approximate number of threads that are actively executing tasks.

Returns:

the number of threads

getMaximumPoolSize

public int getMaximumPoolSize()

Description copied from interface: LocalAwareExecutorService

Returns the maximum allowed number of threads.

Returns:

the maximum allowed number of threads