Modifier and Type	Class and Description
pack-priv static class	ComputationScheduler.EventLoopWorker
pack-priv static class	ComputationScheduler.FixedSchedulerPool
pack-priv static class	ComputationScheduler.PoolWorker

Field Summary

Modifier and Type	Field and Description
private static final String	KEY_COMPUTATION_PRIORITY The name of the system property for setting the thread priority for this Scheduler.
pack-priv static final String	KEY_MAX_THREADS Key to setting the maximum number of computation scheduler threads.
pack-priv static final int	MAX_THREADS The maximum number of computation scheduler threads.
pack-priv static final ComputationScheduler.FixedSchedulerPool	NONE This will indicate no pool is active.
pack-priv final AtomicReference<ComputationScheduler.FixedSchedulerPool>	pool
pack-priv static final ComputationScheduler.PoolWorker	SHUTDOWN_WORKER
pack-priv static final RxThreadFactory	THREAD_FACTORY
private static final String	THREAD_NAME_PREFIX Manages a fixed number of workers.
pack-priv final ThreadFactory	threadFactory

Access	Constructor and Description
public	ComputationScheduler() Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.
public	ComputationScheduler(ThreadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null. threadFactory) Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

Method Summary

Modifier and Type	Method and Description
pack-priv static int	cap(int cpuCount, int paramThreads)
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 void	createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback)
public @NonNull Disposable	scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit)
public @NonNull Disposable	schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit)
public void	shutdown() Overrides io.reactivex.rxjava3.core.Scheduler.shutdown. Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding `Worker` instances and clean up any associated resources with this Scheduler.
public void	start() Overrides io.reactivex.rxjava3.core.Scheduler.start. Allows the Scheduler instance to start threads and accept tasks on them.

Inherited from io.reactivex.rxjava3.core.Scheduler:: clockDriftTolerance now scheduleDirect scheduleDirect schedulePeriodicallyDirect when

Field Detail

KEY_COMPUTATION_PRIORITY	back to summary
private static final String KEY_COMPUTATION_PRIORITY The name of the system property for setting the thread priority for this Scheduler.

KEY_MAX_THREADS	back to summary
pack-priv static final String KEY_MAX_THREADS Key to setting the maximum number of computation scheduler threads. Zero or less is interpreted as use available. Capped by available.

MAX_THREADS	back to summary
pack-priv static final int MAX_THREADS The maximum number of computation scheduler threads.

NONE	back to summary
pack-priv static final ComputationScheduler.FixedSchedulerPool NONE This will indicate no pool is active.

pool	back to summary
pack-priv final AtomicReference<ComputationScheduler.FixedSchedulerPool> pool

SHUTDOWN_WORKER	back to summary
pack-priv static final ComputationScheduler.PoolWorker SHUTDOWN_WORKER

THREAD_FACTORY	back to summary
pack-priv static final RxThreadFactory THREAD_FACTORY

THREAD_NAME_PREFIX	back to summary
private static final String THREAD_NAME_PREFIX Manages a fixed number of workers.

threadFactory	back to summary
pack-priv final ThreadFactory threadFactory

Constructor Detail

ComputationScheduler	back to summary
public ComputationScheduler() Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

ComputationScheduler	back to summary
public ComputationScheduler(ThreadFactory threadFactory) Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy. Parameters threadFactory:ThreadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.

ComputationScheduler

back to summary

public ComputationScheduler(ThreadFactory threadFactory)

Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

Parameters

threadFactory:ThreadFactory: thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.

Method Detail

cap	back to summary
pack-priv static int cap(int cpuCount, int paramThreads)

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

createWorkers	back to summary
public void createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback) Annotations @Override

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

schedulePeriodicallyDirect	back to summary
public @NonNull Disposable schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) Annotations @NonNull @Override

shutdown back to summary

shutdown	back to summary
public void shutdown() Overrides io.reactivex.rxjava3.core.Scheduler.shutdown. Doc from io.reactivex.rxjava3.core.Scheduler.shutdown. Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding `Worker` instances and clean up any associated resources with this Scheduler. Implementations should make sure the call is idempotent, thread-safe and should not throw any `RuntimeException` if it doesn't support this functionality. Annotations @Override

public void shutdown()

Overrides io.reactivex.rxjava3.core.Scheduler.shutdown.

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

Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding Worker instances and clean up any associated resources with this Scheduler.

Implementations should make sure the call is idempotent, thread-safe and should not throw any RuntimeException if it doesn't support this functionality.

Annotations

@Override

start back to summary

start	back to summary
public void start() Overrides io.reactivex.rxjava3.core.Scheduler.start. Doc from io.reactivex.rxjava3.core.Scheduler.start. Allows the Scheduler instance to start threads and accept tasks on them. Implementations should make sure the call is idempotent, thread-safe and should not throw any `RuntimeException` if it doesn't support this functionality. Annotations @Override

public void start()

Overrides io.reactivex.rxjava3.core.Scheduler.start.

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

Allows the Scheduler instance to start threads and accept tasks on them.

Implementations should make sure the call is idempotent, thread-safe and should not throw any RuntimeException if it doesn't support this functionality.

Annotations

@Override

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

pack-priv final Class ComputationScheduler.EventLoopWorker

Class Inheritance

extends Worker

java.lang.Object
io.reactivex.rxjava3.core.Scheduler.Worker
io.reactivex.rxjava3.internal.schedulers.ComputationScheduler.EventLoopWorker

Field Summary

Modifier and Type	Field and Description
private final ListCompositeDisposable	both
pack-priv volatile boolean	disposed
private final ComputationScheduler.PoolWorker	poolWorker
private final ListCompositeDisposable	serial
private final CompositeDisposable	timed

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoopWorker(ComputationScheduler.PoolWorker poolWorker)

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.
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

both	back to summary
private final ListCompositeDisposable both

disposed	back to summary
pack-priv volatile boolean disposed

poolWorker	back to summary
private final ComputationScheduler.PoolWorker poolWorker

serial	back to summary
private final ListCompositeDisposable serial

timed	back to summary
private final CompositeDisposable timed

Constructor Detail

EventLoopWorker	back to summary
pack-priv EventLoopWorker(ComputationScheduler.PoolWorker poolWorker)

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

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 ComputationScheduler.FixedSchedulerPool

Class Inheritance

extends Object
implements SchedulerMultiWorkerSupport

java.lang.Object
io.reactivex.rxjava3.internal.schedulers.ComputationScheduler.FixedSchedulerPool

All Implemented Interfaces

io.reactivex.rxjava3.internal.schedulers.SchedulerMultiWorkerSupport

Field Summary

Modifier and Type	Field and Description
pack-priv final int	cores
pack-priv final ComputationScheduler.PoolWorker[]	eventLoops
pack-priv long	n

Constructor Summary

Access	Constructor and Description
pack-priv	FixedSchedulerPool(int maxThreads, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
public void	createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback)
public ComputationScheduler.PoolWorker	getEventLoop()
public void	shutdown()

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

Field Detail

cores	back to summary
pack-priv final int cores

eventLoops	back to summary
pack-priv final ComputationScheduler.PoolWorker[] eventLoops

n	back to summary
pack-priv long n

Constructor Detail

FixedSchedulerPool	back to summary
pack-priv FixedSchedulerPool(int maxThreads, ThreadFactory threadFactory)

Method Detail

createWorkers	back to summary
public void createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback) Annotations @Override

getEventLoop	back to summary
public ComputationScheduler.PoolWorker getEventLoop()

shutdown	back to summary
public void shutdown()

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

pack-priv final Class ComputationScheduler.PoolWorker

Class Inheritance

extends NewThreadWorker

java.lang.Object
io.reactivex.rxjava3.core.Scheduler.Worker
io.reactivex.rxjava3.internal.schedulers.NewThreadWorker
io.reactivex.rxjava3.internal.schedulers.ComputationScheduler.PoolWorker

Field Summary

Inherited from io.reactivex.rxjava3.internal.schedulers.NewThreadWorker:: disposed

Constructor Summary

Access	Constructor and Description
pack-priv	PoolWorker(ThreadFactory threadFactory)

Method Summary

Inherited from io.reactivex.rxjava3.internal.schedulers.NewThreadWorker:: dispose isDisposed schedule schedule scheduleActual scheduleDirect schedulePeriodicallyDirect shutdown

Constructor Detail

PoolWorker	back to summary
pack-priv PoolWorker(ThreadFactory threadFactory)

public final Class ComputationScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ComputationScheduler.EventLoopWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ComputationScheduler.FixedSchedulerPool

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ComputationScheduler.PoolWorker

Field Summary

Constructor Summary

Method Summary

Constructor Detail