RxJava 2 2.2.21 · io.reactivex.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.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public Disposable	schedule(final Runnable Runnable to schedule run) Overrides io.reactivex.Scheduler.Worker.schedule. Schedules a Runnable for execution without any time delay.
public Disposable	schedule(final Runnable the Runnable to schedule action, long time to "wait" before executing the action; non-positive values indicate an non-delayed schedule delayTime, TimeUnit the time unit of `delayTime` unit) Implements abstract io.reactivex.Scheduler.Worker.schedule. Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.
public ScheduledRunnable	Returns: the ScheduledRunnable instance scheduleActual(final Runnable the runnable instance run, long the time to delay the execution delayTime, TimeUnit the time unit unit, DisposableContainer the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled parent) Wraps 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.Scheduler.Worker:: now 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.disposables.Disposable.dispose. Doc from io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

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

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Doc from io.reactivex.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.disposables.Disposable.isDisposed.

Doc from io.reactivex.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

schedule	back to summary
public Disposable schedule(final Runnable run) Overrides io.reactivex.Scheduler.Worker.schedule. Doc from io.reactivex.Scheduler.Worker.schedule. Schedules a Runnable for execution without any time delay. The default implementation delegates to `schedule(Runnable, long, TimeUnit)`. Parameters run:Runnable Runnable to schedule Returns:Disposable a Disposable to be able to unsubscribe the action (cancel it if not executed) Annotations @NonNull @Override

public Disposable schedule(final Runnable run)

Overrides io.reactivex.Scheduler.Worker.schedule.

Doc from io.reactivex.Scheduler.Worker.schedule.

Schedules a Runnable for execution without any time delay.

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

Parameters

run:Runnable: Runnable to schedule

Returns:Disposable

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

Annotations

@NonNull
@Override

schedule back to summary

schedule	back to summary
public Disposable schedule(final Runnable action, long delayTime, TimeUnit unit) Implements abstract io.reactivex.Scheduler.Worker.schedule. Doc from io.reactivex.Scheduler.Worker.schedule. 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 `schedule(Runnable)` was called. Parameters action:Runnable the Runnable to schedule delayTime:long time to "wait" before executing the action; non-positive values indicate an non-delayed schedule unit:TimeUnit the time unit of `delayTime` Returns:Disposable a Disposable to be able to unsubscribe the action (cancel it if not executed) Annotations @NonNull @Override

public Disposable schedule(final Runnable action, long delayTime, TimeUnit unit)

Implements abstract io.reactivex.Scheduler.Worker.schedule.

Doc from io.reactivex.Scheduler.Worker.schedule.

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 schedule(Runnable) was called.

Parameters

action:Runnable: the Runnable to schedule
delayTime:long: time to "wait" before executing the action; non-positive values indicate an non-delayed schedule
unit:TimeUnit: the time unit of delayTime

Returns:Disposable

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

Annotations

@NonNull
@Override

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

scheduleActual

back to summary

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

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

If the schedule has been rejected, the ScheduledRunnable.wasScheduled will return false.

Parameters

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

Returns: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