org.apache.cassandra.concurrent

Class ImmediateExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.apache.cassandra.concurrent.ImmediateExecutor

All Implemented Interfaces:

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

public class ImmediateExecutor
extends java.util.concurrent.AbstractExecutorService
implements LocalAwareExecutorService

Field Summary

Fields

Modifier and Type	Field and Description
static ImmediateExecutor	INSTANCE

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	execute(java.lang.Runnable command)
void	execute(java.lang.Runnable command, ExecutorLocals locals)
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	getPendingTaskCount() Returns the approximate total of tasks waiting to be executed.
boolean	isShutdown()
boolean	isTerminated()
void	maybeExecuteImmediately(java.lang.Runnable command)
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, 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.LocalAwareExecutorService

getMaxTasksQueued

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Field Detail

INSTANCE

public static final ImmediateExecutor INSTANCE

Method Detail

execute

public void execute(java.lang.Runnable command,
                    ExecutorLocals locals)

Specified by:

execute in interface LocalAwareExecutorService

maybeExecuteImmediately

public void maybeExecuteImmediately(java.lang.Runnable command)

Specified by:

maybeExecuteImmediately in interface LocalAwareExecutorService

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

getActiveTaskCount

public int getActiveTaskCount()

Description copied from interface: LocalAwareExecutorService

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

Specified by:

getActiveTaskCount in interface LocalAwareExecutorService

Returns:

the number of threads

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.

Specified by:

getCompletedTaskCount in interface LocalAwareExecutorService

Returns:

the number of tasks

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.

Specified by:

getPendingTaskCount in interface LocalAwareExecutorService

Returns:

the number of tasks

getMaximumPoolSize

public int getMaximumPoolSize()

Description copied from interface: LocalAwareExecutorService

Returns the maximum allowed number of threads.

Specified by:

getMaximumPoolSize in interface LocalAwareExecutorService

Returns:

the maximum allowed number of threads

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

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

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

awaitTermination

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

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService