Class ExecutorScheduler.ExecutorWorker.InterruptibleRunnable

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.schedulers.ExecutorScheduler.ExecutorWorker.InterruptibleRunnable

All Implemented Interfaces:

Disposable, Serializable, Runnable

Enclosing class:

ExecutorScheduler.ExecutorWorker

static final class ExecutorScheduler.ExecutorWorker.InterruptibleRunnable
extends AtomicInteger
implements Runnable, Disposable

Wrapper for a Runnable with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final int	FINISHED
(package private) static final int	INTERRUPTED
(package private) static final int	INTERRUPTING
(package private) static final int	READY
(package private) final Runnable	run
(package private) static final int	RUNNING
private static final long	serialVersionUID
(package private) final DisposableContainer	tasks
(package private) Thread	thread

Constructor Summary

Constructors

Constructor	Description
InterruptibleRunnable(Runnable run, DisposableContainer tasks)

Method Summary

Modifier and Type	Method	Description
(package private) void	cleanup()
void	dispose()	Dispose the resource, the operation should be idempotent.
boolean	isDisposed()	Returns true if this resource has been disposed.
void	run()

Methods inherited from class AtomicInteger

accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Number

byteValue, shortValue

Methods inherited from class Object

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

run

final Runnable run

tasks

final DisposableContainer tasks

thread

volatile Thread thread

READY

static final int READY

See Also:

• Constant Field Values

RUNNING

static final int RUNNING

See Also:

• Constant Field Values

FINISHED

static final int FINISHED

See Also:

• Constant Field Values

INTERRUPTING

static final int INTERRUPTING

See Also:

• Constant Field Values

INTERRUPTED

static final int INTERRUPTED

See Also:

• Constant Field Values

Constructor Details

InterruptibleRunnable

InterruptibleRunnable(Runnable run,
 DisposableContainer tasks)

Method Details

run

public void run()

Specified by:

run in interface Runnable

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

cleanup

void cleanup()

isDisposed

public boolean isDisposed()

Description copied from interface: Disposable

Returns true if this resource has been disposed.

Specified by:

isDisposed in interface Disposable

Returns:

true if this resource has been disposed