RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.schedulers.NewThreadWorker

Modifier and Type	Field and Description
pack-priv volatile boolean	disposed
private final ScheduledExecutorService	executor

Access	Constructor and Description
public	NewThreadWorker(ThreadFactory threadFactory)

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(final @NonNull Runnable run)
public @NonNull Disposable	schedule(final @NonNull Runnable action, long delayTime, @NonNull TimeUnit unit)
public @NonNull ScheduledRunnable	Returns: the ScheduledRunnable instance scheduleActual(final Runnable the runnable instance run, long the time to delay the execution delayTime, @NonNull TimeUnit the time unit unit, @Nullable DisposableContainer the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled parent) Wraps and returns the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService.
public Disposable	Returns: the ScheduledRunnable instance scheduleDirect(final Runnable the Runnable to execute in a delayed fashion run, long the delay amount delayTime, TimeUnit the delay time unit unit) Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable.
public Disposable	Returns: the ScheduledRunnable instance schedulePeriodicallyDirect(Runnable the Runnable to execute in a periodic fashion run, long the initial delay amount initialDelay, long the repeat period amount period, TimeUnit the time unit for both the initialDelay and period unit) Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable.
public void	shutdown() Shuts down the underlying executor in a non-interrupting fashion.

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

disposed	back to summary
pack-priv volatile boolean disposed

executor	back to summary
private final ScheduledExecutorService executor

NewThreadWorker	back to summary
public NewThreadWorker(ThreadFactory threadFactory)

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(final @NonNull Runnable run) Annotations @NonNull @Override

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

scheduleActual	back to summary
public @NonNull ScheduledRunnable scheduleActual(final Runnable run, long delayTime, @NonNull TimeUnit unit, @Nullable DisposableContainer parent) Wraps and returns the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService. Parameters run:Runnable the runnable instance delayTime:long the time to delay the execution unit:@NonNull TimeUnit the time unit parent:@Nullable DisposableContainer the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled Returns:@NonNull ScheduledRunnable the ScheduledRunnable instance Annotations @NonNull

scheduleActual

back to summary

public @NonNull ScheduledRunnable scheduleActual(final Runnable run, long delayTime, @NonNull TimeUnit unit, @Nullable DisposableContainer parent)

Wraps and returns the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService.

Parameters

run:Runnable: the runnable instance
delayTime:long: the time to delay the execution
unit:@NonNull TimeUnit: the time unit
parent:@Nullable DisposableContainer: the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled

Returns:@NonNull ScheduledRunnable

the ScheduledRunnable instance

Annotations

@NonNull

scheduleDirect	back to summary
public Disposable scheduleDirect(final Runnable run, long delayTime, TimeUnit unit) Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable. Parameters run:Runnable the Runnable to execute in a delayed fashion delayTime:long the delay amount unit:TimeUnit the delay time unit Returns:Disposable the ScheduledRunnable instance

scheduleDirect

back to summary

public Disposable scheduleDirect(final Runnable run, long delayTime, TimeUnit unit)

Schedules the given runnable on the underlying executor directly and returns its future wrapped into a Disposable.

Parameters

run:Runnable: the Runnable to execute in a delayed fashion
delayTime:long: the delay amount
unit:TimeUnit: the delay time unit

Returns:Disposable

the ScheduledRunnable instance

schedulePeriodicallyDirect	back to summary
public Disposable schedulePeriodicallyDirect(Runnable run, long initialDelay, long period, TimeUnit unit) Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable. Parameters run:Runnable the Runnable to execute in a periodic fashion initialDelay:long the initial delay amount period:long the repeat period amount unit:TimeUnit the time unit for both the initialDelay and period Returns:Disposable the ScheduledRunnable instance

schedulePeriodicallyDirect

back to summary

public Disposable schedulePeriodicallyDirect(Runnable run, long initialDelay, long period, TimeUnit unit)

Schedules the given runnable periodically on the underlying executor directly and returns its future wrapped into a Disposable.

Parameters

run:Runnable: the Runnable to execute in a periodic fashion
initialDelay:long: the initial delay amount
period:long: the repeat period amount
unit:TimeUnit: the time unit for both the initialDelay and period

Returns:Disposable

the ScheduledRunnable instance

shutdown	back to summary
public void shutdown() Shuts down the underlying executor in a non-interrupting fashion.

public Class NewThreadWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail