Package org.apache.cassandra.concurrent

Class InfiniteLoopExecutor

java.lang.Object

org.apache.cassandra.concurrent.InfiniteLoopExecutor

All Implemented Interfaces:

Interruptible, Shutdownable

public class InfiniteLoopExecutor
extends Object
implements Interruptible

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	InfiniteLoopExecutor.Daemon
static enum	InfiniteLoopExecutor.InternalState
static enum	InfiniteLoopExecutor.Interrupts
static enum	InfiniteLoopExecutor.SimulatorSafe

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

Interruptible.SimpleTask, Interruptible.State, Interruptible.Task, Interruptible.TerminateException

Constructor Summary

Constructors

Constructor	Description
InfiniteLoopExecutor(String name, Interruptible.Task task, InfiniteLoopExecutor.Daemon daemon)
InfiniteLoopExecutor(BiFunction<String,Runnable,Thread> threadStarter, String name, Interruptible.Task task, InfiniteLoopExecutor.Interrupts interrupts)
InfiniteLoopExecutor(ExecutorFactory factory, String name, Interruptible.Task task, InfiniteLoopExecutor.Daemon daemon)
InfiniteLoopExecutor(ExecutorFactory factory, String name, Interruptible.Task task, InfiniteLoopExecutor.Daemon daemon, InfiniteLoopExecutor.Interrupts interrupts)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long time, TimeUnit unit)	Await termination of this object, i.e.
void	interrupt()
boolean	isAlive()
boolean	isTerminated()
void	shutdown()	Shutdown once any remaining work has completed (however this is defined for the implementation).
Object	shutdownNow()	Shutdown immediately, possibly interrupting ongoing work, and cancelling work that is queued.

Methods inherited from class java.lang.Object

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

Constructor Details

InfiniteLoopExecutor

public InfiniteLoopExecutor(String name,
 Interruptible.Task task,
 InfiniteLoopExecutor.Daemon daemon)

InfiniteLoopExecutor

public InfiniteLoopExecutor(ExecutorFactory factory,
 String name,
 Interruptible.Task task,
 InfiniteLoopExecutor.Daemon daemon)

InfiniteLoopExecutor

public InfiniteLoopExecutor(ExecutorFactory factory,
 String name,
 Interruptible.Task task,
 InfiniteLoopExecutor.Daemon daemon,
 InfiniteLoopExecutor.Interrupts interrupts)

InfiniteLoopExecutor

public InfiniteLoopExecutor(BiFunction<String,Runnable,Thread> threadStarter,
 String name,
 Interruptible.Task task,
 InfiniteLoopExecutor.Interrupts interrupts)

Method Details

interrupt

public void interrupt()

Specified by:

interrupt in interface Interruptible

shutdown

public void shutdown()

Description copied from interface: Shutdownable

Shutdown once any remaining work has completed (however this is defined for the implementation).

Specified by:

shutdown in interface Shutdownable

shutdownNow

public Object shutdownNow()

Description copied from interface: Shutdownable

Shutdown immediately, possibly interrupting ongoing work, and cancelling work that is queued.

Specified by:

shutdownNow in interface Shutdownable

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface Shutdownable

awaitTermination

public boolean awaitTermination(long time,
 TimeUnit unit)
                         throws InterruptedException

Description copied from interface: Shutdownable

Await termination of this object, i.e. the cessation of all current and future work.

Specified by:

awaitTermination in interface Shutdownable

Throws:

InterruptedException

isAlive

public boolean isAlive()