Modifier and Type	Class and Description
pack-priv static class	TrampolineScheduler.SleepingRunnable
pack-priv static class	TrampolineScheduler.TimedRunnable
pack-priv static class	TrampolineScheduler.TrampolineWorker

Modifier and Type	Field and Description
private static final TrampolineScheduler	INSTANCE

Access	Constructor and Description
pack-priv	TrampolineScheduler()

Modifier and Type	Method and Description
public @NonNull Scheduler.Worker	createWorker() Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions.
public static TrampolineScheduler	instance()
public @NonNull Disposable	scheduleDirect(@NonNull Runnable run)
public @NonNull Disposable	scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit)

INSTANCE	back to summary
private static final TrampolineScheduler INSTANCE

TrampolineScheduler	back to summary
pack-priv TrampolineScheduler()

Method Detail

createWorker back to summary

createWorker	back to summary
public @NonNull Scheduler.Worker createWorker() Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker. Doc from io.reactivex.rxjava3.core.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions. When work is completed, the `Worker` instance should be released by calling `Scheduler.Worker#dispose()` to avoid potential resource leaks in the underlying task-execution scheme. Work on a `Scheduler.Worker` is guaranteed to be sequential and non-overlapping. Returns:@NonNull Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @NonNull @Override

public @NonNull Scheduler.Worker createWorker()

Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker.

Doc from io.reactivex.rxjava3.core.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents sequential execution of actions.

When work is completed, the Worker instance should be released by calling Scheduler.Worker#dispose() to avoid potential resource leaks in the underlying task-execution scheme.

Work on a Scheduler.Worker is guaranteed to be sequential and non-overlapping.

Returns:@NonNull Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations

@NonNull
@Override

instance	back to summary
public static TrampolineScheduler instance()

scheduleDirect	back to summary
public @NonNull Disposable scheduleDirect(@NonNull Runnable run) Annotations @NonNull @Override

scheduleDirect	back to summary
public @NonNull Disposable scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit) Annotations @NonNull @Override

io.reactivex.rxjava3.internal.schedulers back to summary

pack-priv final Class TrampolineScheduler.SleepingRunnable

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.rxjava3.internal.schedulers.TrampolineScheduler.SleepingRunnable

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final long	execTime
private final Runnable	run
private final TrampolineScheduler.TrampolineWorker	worker

Constructor Summary

Access	Constructor and Description
pack-priv	SleepingRunnable(Runnable run, TrampolineScheduler.TrampolineWorker worker, long execTime)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

execTime	back to summary
private final long execTime

run	back to summary
private final Runnable run

worker	back to summary
private final TrampolineScheduler.TrampolineWorker worker

Constructor Detail

SleepingRunnable	back to summary
pack-priv SleepingRunnable(Runnable run, TrampolineScheduler.TrampolineWorker worker, long execTime)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.reactivex.rxjava3.internal.schedulers back to summary

pack-priv final Class TrampolineScheduler.TimedRunnable

Class Inheritance

extends Object
implements Comparable<TrampolineScheduler.TimedRunnable>

java.lang.Object
io.reactivex.rxjava3.internal.schedulers.TrampolineScheduler.TimedRunnable

All Implemented Interfaces

java.lang.Comparable

Field Summary

Modifier and Type	Field and Description
pack-priv final int	count
pack-priv volatile boolean	disposed
pack-priv final long	execTime
pack-priv final Runnable	run

Constructor Summary

Access	Constructor and Description
pack-priv	TimedRunnable(Runnable run, Long execTime, int count)

Method Summary

Modifier and Type	Method and Description
public int	compareTo(TrampolineScheduler.TimedRunnable the object to be compared. that) Implements java.lang.Comparable.compareTo. Compares this object with the specified object for order.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

count	back to summary
pack-priv final int count

disposed	back to summary
pack-priv volatile boolean disposed

execTime	back to summary
pack-priv final long execTime

run	back to summary
pack-priv final Runnable run

Constructor Detail

TimedRunnable	back to summary
pack-priv TimedRunnable(Runnable run, Long execTime, int count)

Method Detail

compareTo back to summary

compareTo	back to summary
public int compareTo(TrampolineScheduler.TimedRunnable that) Implements java.lang.Comparable.compareTo. Doc from java.lang.Comparable.compareTo. Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object. The implementor must ensure `signum(x.compareTo(y)) == -signum(y.compareTo(x))` for all `x` and `y`. (This implies that `x.compareTo(y)` must throw an exception if and only if `y.compareTo(x)` throws an exception.) The implementor must also ensure that the relation is transitive: `(x.compareTo(y) > 0 && y.compareTo(z) > 0)` implies `x.compareTo(z) > 0`. Finally, the implementor must ensure that `x.compareTo(y)==0` implies that `signum(x.compareTo(z)) == signum(y.compareTo(z))`, for all `z`. Parameters that:TrampolineScheduler.TimedRunnable the object to be compared. Returns:int a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object. Annotations @Override

public int compareTo(TrampolineScheduler.TimedRunnable that)

Implements java.lang.Comparable.compareTo.

Doc from java.lang.Comparable.compareTo.

Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object.

The implementor must ensure signum(x.compareTo(y)) == -signum(y.compareTo(x)) for all x and y. (This implies that x.compareTo(y) must throw an exception if and only if y.compareTo(x) throws an exception.)

The implementor must also ensure that the relation is transitive: (x.compareTo(y) > 0 && y.compareTo(z) > 0) implies x.compareTo(z) > 0.

Finally, the implementor must ensure that x.compareTo(y)==0 implies that signum(x.compareTo(z)) == signum(y.compareTo(z)), for all z.

Parameters

that:TrampolineScheduler.TimedRunnable: the object to be compared.

Returns:int

a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object.

Annotations

@Override

io.reactivex.rxjava3.internal.schedulers back to summary

pack-priv final Class TrampolineScheduler.TrampolineWorker

Class Inheritance

extends Worker

java.lang.Object
io.reactivex.rxjava3.core.Scheduler.Worker
io.reactivex.rxjava3.internal.schedulers.TrampolineScheduler.TrampolineWorker

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	TrampolineScheduler.TrampolineWorker.AppendToQueueTask

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicInteger	counter
pack-priv volatile boolean	disposed
pack-priv final PriorityBlockingQueue<TrampolineScheduler.TimedRunnable>	queue
private final AtomicInteger	wip

Constructor Summary

Access	Constructor and Description
pack-priv	TrampolineWorker()

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
pack-priv Disposable	enqueue(Runnable action, long execTime)
public boolean	isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public @NonNull Disposable	schedule(@NonNull Runnable action)
public @NonNull Disposable	schedule(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit)

Inherited from io.reactivex.rxjava3.core.Scheduler.Worker:: now schedule schedule schedulePeriodically

Field Detail

counter	back to summary
pack-priv final AtomicInteger counter

disposed	back to summary
pack-priv volatile boolean disposed

queue	back to summary
pack-priv final PriorityBlockingQueue<TrampolineScheduler.TimedRunnable> queue

wip	back to summary
private final AtomicInteger wip

Constructor Detail

TrampolineWorker	back to summary
pack-priv TrampolineWorker()

Method Detail

dispose	back to summary
public void dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

enqueue	back to summary
pack-priv Disposable enqueue(Runnable action, long execTime)

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

schedule	back to summary
public @NonNull Disposable schedule(@NonNull Runnable action) Annotations @NonNull @Override

schedule	back to summary
public @NonNull Disposable schedule(@NonNull Runnable action, long delayTime, @NonNull TimeUnit unit) Annotations @NonNull @Override

io.reactivex.rxjava3.internal.schedulers back to summary

pack-priv final Class TrampolineScheduler.TrampolineWorker.AppendToQueueTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.rxjava3.internal.schedulers.TrampolineScheduler.TrampolineWorker.AppendToQueueTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final TrampolineScheduler.TimedRunnable	timedRunnable

Constructor Summary

Access	Constructor and Description
pack-priv	AppendToQueueTask(TrampolineScheduler.TimedRunnable timedRunnable)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

timedRunnable	back to summary
pack-priv final TrampolineScheduler.TimedRunnable timedRunnable

Constructor Detail

AppendToQueueTask	back to summary
pack-priv AppendToQueueTask(TrampolineScheduler.TimedRunnable timedRunnable)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

public final Class TrampolineScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TrampolineScheduler.SleepingRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TrampolineScheduler.TimedRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TrampolineScheduler.TrampolineWorker

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TrampolineScheduler.TrampolineWorker.AppendToQueueTask

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail