Package org.apache.cassandra.concurrent

Class ExecutorFactory.Default

java.lang.Object

org.apache.cassandra.concurrent.NamedThreadFactory.MetaFactory

org.apache.cassandra.concurrent.ExecutorFactory.Default

All Implemented Interfaces:

ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus>, ExecutorBuilderFactory.Jmxable<ExecutorPlus,SequentialExecutorPlus>, ExecutorFactory

Enclosing interface:

ExecutorFactory

public static final class ExecutorFactory.Default
extends NamedThreadFactory.MetaFactory
implements ExecutorFactory

Nested Class Summary

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

ExecutorBuilderFactory.Jmxable<E extends ExecutorPlus,S extends SequentialExecutorPlus>

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

ExecutorFactory.Default, ExecutorFactory.Global, ExecutorFactory.LocalAwareSubFactory, ExecutorFactory.LocalAwareSubFactoryWithJMX, ExecutorFactory.SimulatorSemantics

Field Summary

Fields inherited from class org.apache.cassandra.concurrent.NamedThreadFactory.MetaFactory

contextClassLoader, threadGroup, uncaughtExceptionHandler

Constructor Summary

Constructors

Constructor	Description
Default(ClassLoader contextClassLoader, ThreadGroup threadGroup, Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Method Summary

Modifier and Type	Method	Description
ExecutorBuilder<ThreadPoolExecutorPlus>	configurePooled(String name, int threads)	Configure a pooled executor with the requested number of threads
ExecutorBuilder<SingleThreadExecutorPlus>	configureSequential(String name)	Configure a sequential (single threaded) executor
Interruptible	infiniteLoop(String name, Interruptible.Task task, InfiniteLoopExecutor.SimulatorSafe simulatorSafe, InfiniteLoopExecutor.Daemon daemon, InfiniteLoopExecutor.Interrupts interrupts)	Create and start a new InfiniteLoopExecutor to repeatedly invoke runnable.
ExecutorFactory.LocalAwareSubFactory	localAware()
ThreadGroup	newThreadGroup(String name)	Create a new thread group for use with builders - this thread group will be situated within this factory's parent thread group, and may be supplied to multiple executor builders.
ScheduledExecutorPlus	scheduled(boolean executeOnShutdown, String name, int priority, ExecutorFactory.SimulatorSemantics simulatorSemantics)
Thread	startThread(String name, Runnable runnable, InfiniteLoopExecutor.Daemon daemon)	Create and start a new thread to execute runnable
ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus>	withJmx(String jmxPath)

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.ExecutorBuilderFactory

pooled, sequential

Methods inherited from interface org.apache.cassandra.concurrent.ExecutorBuilderFactory.Jmxable

withJmxInternal

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

infiniteLoop, scheduled, scheduled, scheduled, scheduled, startThread

Constructor Details

Default

public Default(ClassLoader contextClassLoader,
 ThreadGroup threadGroup,
 Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Method Details

localAware

public ExecutorFactory.LocalAwareSubFactory localAware()

Specified by:

localAware in interface ExecutorFactory

Returns:

a factory that configures executors that propagate ExecutorLocals to the executing thread

withJmx

public ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus> withJmx(String jmxPath)

Specified by:

withJmx in interface ExecutorBuilderFactory.Jmxable<ExecutorPlus,SequentialExecutorPlus>

Returns:

a factory that configures executors that register against JMX using the provided jmx path

configureSequential

public ExecutorBuilder<SingleThreadExecutorPlus> configureSequential(String name)

Description copied from interface: ExecutorBuilderFactory

Configure a sequential (single threaded) executor

Specified by:

configureSequential in interface ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus>

configurePooled

public ExecutorBuilder<ThreadPoolExecutorPlus> configurePooled(String name,
 int threads)

Description copied from interface: ExecutorBuilderFactory

Configure a pooled executor with the requested number of threads

Specified by:

configurePooled in interface ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus>

scheduled

public ScheduledExecutorPlus scheduled(boolean executeOnShutdown,
 String name,
 int priority,
 ExecutorFactory.SimulatorSemantics simulatorSemantics)

Specified by:

scheduled in interface ExecutorFactory

Parameters:

executeOnShutdown - if false, waiting tasks will be cancelled on shutdown

name - the name of the executor, the executor's thread group, and of any worker threads

priority - the thread priority of workers

simulatorSemantics - indicate special semantics for the executor under simulation

Returns:

a ScheduledExecutorPlus

startThread

public Thread startThread(String name,
 Runnable runnable,
 InfiniteLoopExecutor.Daemon daemon)

Description copied from interface: ExecutorFactory

Create and start a new thread to execute runnable

Specified by:

startThread in interface ExecutorFactory

Parameters:

name - the name of the thread

runnable - the task to execute

daemon - flag to indicate whether the thread should be a daemon or not

Returns:

the new thread

infiniteLoop

public Interruptible infiniteLoop(String name,
 Interruptible.Task task,
 InfiniteLoopExecutor.SimulatorSafe simulatorSafe,
 InfiniteLoopExecutor.Daemon daemon,
 InfiniteLoopExecutor.Interrupts interrupts)

Description copied from interface: ExecutorFactory

Create and start a new InfiniteLoopExecutor to repeatedly invoke runnable. On shutdown, the executing thread will be interrupted; to support clean shutdown runnable should propagate InterruptedException

Specified by:

infiniteLoop in interface ExecutorFactory

Parameters:

name - the name of the thread used to invoke the task repeatedly

task - the task to execute repeatedly

simulatorSafe - flag indicating if the loop thread can be intercepted / rescheduled during cluster simulation

daemon - flag to indicate whether the loop thread should be a daemon thread or not

interrupts - flag to indicate whether to synchronize interrupts of the task execution thread using the task's monitor this can be used to prevent interruption while performing IO operations which forbid interrupted threads. See: AbstractCommitLogSegmentManager.start()

Returns:

the new thread

newThreadGroup

public ThreadGroup newThreadGroup(String name)

Description copied from interface: ExecutorFactory

Create a new thread group for use with builders - this thread group will be situated within this factory's parent thread group, and may be supplied to multiple executor builders.

Specified by:

newThreadGroup in interface ExecutorFactory