hu.akarnokd.rxjava2.internal.schedulers

Class TrampolineScheduler

java.lang.Object

hu.akarnokd.rxjava2.Scheduler

hu.akarnokd.rxjava2.internal.schedulers.TrampolineScheduler

public final class TrampolineScheduler
extends Scheduler

Schedules work on the current thread but does not execute immediately. Work is put in a queue and executed after the current unit of work is completed.

Nested Class Summary

Nested classes/interfaces inherited from class hu.akarnokd.rxjava2.Scheduler

Scheduler.Worker

Method Summary

Modifier and Type	Method and Description
Scheduler.Worker	createWorker()
static TrampolineScheduler	instance()
Disposable	scheduleDirect(java.lang.Runnable run)
Disposable	scheduleDirect(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit) Schedules the given runnable with the given delay directly on a worker of this scheduler.

Methods inherited from class hu.akarnokd.rxjava2.Scheduler

now, schedulePeriodicallyDirect, shutdown, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

instance

public static TrampolineScheduler instance()

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker in class Scheduler

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run)

Overrides:

scheduleDirect in class Scheduler

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run,
                                 long delay,
                                 java.util.concurrent.TimeUnit unit)

Description copied from class: Scheduler

Schedules the given runnable with the given delay directly on a worker of this scheduler.

Override this method to provide an efficient implementation that, for example, doesn't have extra tracking structures for such one-shot executions.

Overrides:

scheduleDirect in class Scheduler

Parameters:

run - the runnable to schedule

delay - the delay time

unit - the delay unit

Returns:

the disposable instance that can cancel the task