Modifier and Type	Class and Description
pack-priv static class	IoScheduler.CachedWorkerPool
pack-priv static class	IoScheduler.EventLoopWorker
pack-priv static class	IoScheduler.ThreadWorker

Field Summary

Modifier and Type	Field and Description
pack-priv static final RxThreadFactory	EVICTOR_THREAD_FACTORY
private static final String	EVICTOR_THREAD_NAME_PREFIX
private static final long	KEEP_ALIVE_TIME
public static final long	KEEP_ALIVE_TIME_DEFAULT
private static final TimeUnit	KEEP_ALIVE_UNIT
private static final String	KEY_IO_PRIORITY The name of the system property for setting the thread priority for this Scheduler.
private static final String	KEY_KEEP_ALIVE_TIME The name of the system property for setting the keep-alive time (in seconds) for this Scheduler workers.
private static final String	KEY_SCHEDULED_RELEASE The name of the system property for setting the release behaviour for this Scheduler.
pack-priv static final IoScheduler.CachedWorkerPool	NONE
pack-priv final AtomicReference<IoScheduler.CachedWorkerPool>	pool
pack-priv static final IoScheduler.ThreadWorker	SHUTDOWN_THREAD_WORKER
pack-priv final ThreadFactory	threadFactory
pack-priv static boolean	USE_SCHEDULED_RELEASE
pack-priv static final RxThreadFactory	WORKER_THREAD_FACTORY
private static final String	WORKER_THREAD_NAME_PREFIX

Access	Constructor and Description
public	IoScheduler()
public	IoScheduler(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) Constructs an IoScheduler with the given thread factory and starts the pool of workers.

Method Summary

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 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 int	size()
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

EVICTOR_THREAD_FACTORY	back to summary
pack-priv static final RxThreadFactory EVICTOR_THREAD_FACTORY

EVICTOR_THREAD_NAME_PREFIX	back to summary
private static final String EVICTOR_THREAD_NAME_PREFIX

KEEP_ALIVE_TIME	back to summary
private static final long KEEP_ALIVE_TIME

KEEP_ALIVE_TIME_DEFAULT	back to summary
public static final long KEEP_ALIVE_TIME_DEFAULT

KEEP_ALIVE_UNIT	back to summary
private static final TimeUnit KEEP_ALIVE_UNIT

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

KEY_KEEP_ALIVE_TIME	back to summary
private static final String KEY_KEEP_ALIVE_TIME The name of the system property for setting the keep-alive time (in seconds) for this Scheduler workers.

KEY_SCHEDULED_RELEASE	back to summary
private static final String KEY_SCHEDULED_RELEASE The name of the system property for setting the release behaviour for this Scheduler.

NONE	back to summary
pack-priv static final IoScheduler.CachedWorkerPool NONE

pool	back to summary
pack-priv final AtomicReference<IoScheduler.CachedWorkerPool> pool

SHUTDOWN_THREAD_WORKER	back to summary
pack-priv static final IoScheduler.ThreadWorker SHUTDOWN_THREAD_WORKER

threadFactory	back to summary
pack-priv final ThreadFactory threadFactory

USE_SCHEDULED_RELEASE	back to summary
pack-priv static boolean USE_SCHEDULED_RELEASE

WORKER_THREAD_FACTORY	back to summary
pack-priv static final RxThreadFactory WORKER_THREAD_FACTORY

WORKER_THREAD_NAME_PREFIX	back to summary
private static final String WORKER_THREAD_NAME_PREFIX

IoScheduler	back to summary
public IoScheduler()

IoScheduler	back to summary
public IoScheduler(ThreadFactory threadFactory) Constructs an IoScheduler with the given thread factory and starts the pool of workers. 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

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

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

size	back to summary
public int size()

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

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.rxjava3.internal.schedulers.IoScheduler.CachedWorkerPool

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final CompositeDisposable	allWorkers
private final ScheduledExecutorService	evictorService
private final Future<?>	evictorTask
private final ConcurrentLinkedQueue<IoScheduler.ThreadWorker>	expiringWorkerQueue
private final long	keepAliveTime
private final ThreadFactory	threadFactory

Constructor Summary

Access	Constructor and Description
pack-priv	CachedWorkerPool(long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
pack-priv static void	evictExpiredWorkers(ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue, CompositeDisposable allWorkers)
pack-priv IoScheduler.ThreadWorker	get()
pack-priv static long	now()
pack-priv void	release(IoScheduler.ThreadWorker threadWorker)
public void	run() Implements java.lang.Runnable.run. Runs this operation.
pack-priv void	shutdown()

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

Field Detail

allWorkers	back to summary
pack-priv final CompositeDisposable allWorkers

evictorService	back to summary
private final ScheduledExecutorService evictorService

evictorTask	back to summary
private final Future<?> evictorTask

expiringWorkerQueue	back to summary
private final ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue

keepAliveTime	back to summary
private final long keepAliveTime

threadFactory	back to summary
private final ThreadFactory threadFactory

Constructor Detail

CachedWorkerPool	back to summary
pack-priv CachedWorkerPool(long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory)

Method Detail

evictExpiredWorkers	back to summary
pack-priv static void evictExpiredWorkers(ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue, CompositeDisposable allWorkers)

get	back to summary
pack-priv IoScheduler.ThreadWorker get()

now	back to summary
pack-priv static long now()

release	back to summary
pack-priv void release(IoScheduler.ThreadWorker threadWorker)

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

shutdown	back to summary
pack-priv void shutdown()

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

pack-priv final Class IoScheduler.EventLoopWorker

Class Inheritance

extends Worker
implements Runnable

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

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicBoolean	once
private final IoScheduler.CachedWorkerPool	pool
private final CompositeDisposable	tasks
private final IoScheduler.ThreadWorker	threadWorker

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoopWorker(IoScheduler.CachedWorkerPool pool)

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 void	run() Implements java.lang.Runnable.run. Runs this operation.
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

once	back to summary
pack-priv final AtomicBoolean once

pool	back to summary
private final IoScheduler.CachedWorkerPool pool

tasks	back to summary
private final CompositeDisposable tasks

threadWorker	back to summary
private final IoScheduler.ThreadWorker threadWorker

Constructor Detail

EventLoopWorker	back to summary
pack-priv EventLoopWorker(IoScheduler.CachedWorkerPool pool)

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