Class ExecutorScheduler.ExecutorWorker

java.lang.Object

io.reactivex.rxjava3.core.Scheduler.Worker

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

All Implemented Interfaces:

Disposable, Runnable

Enclosing class:

ExecutorScheduler

public static final class ExecutorScheduler.ExecutorWorker
extends Scheduler.Worker
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ExecutorScheduler.ExecutorWorker.BooleanRunnable
(package private) static final class	ExecutorScheduler.ExecutorWorker.InterruptibleRunnable	Wrapper for a Runnable with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.
(package private) final class	ExecutorScheduler.ExecutorWorker.SequentialDispose

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	disposed
(package private) final Executor	executor
(package private) final boolean	fair
(package private) final boolean	interruptibleWorker
(package private) final MpscLinkedQueue<Runnable>	queue
(package private) final CompositeDisposable	tasks
(package private) final AtomicInteger	wip

Constructor Summary

Constructors

Constructor	Description
ExecutorWorker(Executor executor, boolean interruptibleWorker, boolean fair)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Dispose the resource, the operation should be idempotent.
boolean	isDisposed()	Returns true if this resource has been disposed.
void	run()
(package private) void	runEager()
(package private) void	runFair()
@NonNull Disposable	schedule(@NonNull Runnable run)	Schedules a Runnable for execution without any time delay.
@NonNull Disposable	schedule(@NonNull Runnable run, long delay, @NonNull TimeUnit unit)	Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

Methods inherited from class Scheduler.Worker

now, schedulePeriodically

Methods inherited from class Object

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

Field Details

interruptibleWorker

final boolean interruptibleWorker

fair

final boolean fair

executor

final Executor executor

queue

final MpscLinkedQueue<Runnable> queue

disposed

volatile boolean disposed

wip

final AtomicInteger wip

tasks

final CompositeDisposable tasks

Constructor Details

ExecutorWorker

public ExecutorWorker(Executor executor,
 boolean interruptibleWorker,
 boolean fair)

Method Details

schedule

@NonNull
public @NonNull Disposable schedule(@NonNull
 @NonNull Runnable run)

Description copied from class: Scheduler.Worker

Schedules a Runnable for execution without any time delay.

The default implementation delegates to Scheduler.Worker.schedule(Runnable, long, TimeUnit).

Overrides:

schedule in class Scheduler.Worker

Parameters:

run - Runnable to schedule

Returns:

a Disposable to be able to unsubscribe the action (cancel it if not executed)

schedule

@NonNull
public @NonNull Disposable schedule(@NonNull
 @NonNull Runnable run,
 long delay,
 @NonNull
 @NonNull TimeUnit unit)

Description copied from class: Scheduler.Worker

Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

Note to implementors: non-positive delayTime should be regarded as non-delayed schedule, i.e., as if the Scheduler.Worker.schedule(Runnable) was called.

Specified by:

schedule in class Scheduler.Worker

Parameters:

run - the Runnable to schedule

delay - time to "wait" before executing the action; non-positive values indicate an non-delayed schedule

unit - the time unit of delayTime

Returns:

a Disposable to be able to unsubscribe the action (cancel it if not executed)

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

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

run

public void run()

Specified by:

run in interface Runnable

runFair

void runFair()

runEager

void runEager()