Package org.apache.cassandra.concurrent

Class SingleThreadExecutorPlus.AtLeastOnce

java.lang.Object

java.util.concurrent.atomic.AtomicBoolean

org.apache.cassandra.concurrent.SingleThreadExecutorPlus.AtLeastOnce

All Implemented Interfaces:

Serializable, Runnable, SequentialExecutorPlus.AtLeastOnceTrigger

Enclosing class:

SingleThreadExecutorPlus

public static class SingleThreadExecutorPlus.AtLeastOnce
extends AtomicBoolean
implements SequentialExecutorPlus.AtLeastOnceTrigger, Runnable

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected final SequentialExecutorPlus	executor
protected final Runnable	run

Constructor Summary

Constructors

Constructor	Description
AtLeastOnce(SequentialExecutorPlus executor, Runnable run)

Method Summary

Modifier and Type	Method	Description
void	run()
void	runAfter(Runnable run)	Run the provided task after all queued and executing jobs have completed
void	sync()	Wait until all queued and executing jobs have completed
String	toString()
boolean	trigger()	Ensure the job is run at least once in its entirety after this method is invoked (including any already queued)

Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndSet, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class java.lang.Object

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

Field Details

executor

protected final SequentialExecutorPlus executor

run

protected final Runnable run

Constructor Details

AtLeastOnce

public AtLeastOnce(SequentialExecutorPlus executor,
 Runnable run)

Method Details

trigger

public boolean trigger()

Description copied from interface: SequentialExecutorPlus.AtLeastOnceTrigger

Ensure the job is run at least once in its entirety after this method is invoked (including any already queued)

Specified by:

trigger in interface SequentialExecutorPlus.AtLeastOnceTrigger

runAfter

public void runAfter(Runnable run)

Description copied from interface: SequentialExecutorPlus.AtLeastOnceTrigger

Run the provided task after all queued and executing jobs have completed

Specified by:

runAfter in interface SequentialExecutorPlus.AtLeastOnceTrigger

sync

public void sync()

Description copied from interface: SequentialExecutorPlus.AtLeastOnceTrigger

Wait until all queued and executing jobs have completed

Specified by:

sync in interface SequentialExecutorPlus.AtLeastOnceTrigger

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class AtomicBoolean