hu.akarnokd.rxjava2

Class Scheduler

java.lang.Object

hu.akarnokd.rxjava2.Scheduler

Direct Known Subclasses:

ComputationScheduler, ExecutorScheduler, IOScheduler, NewThreadScheduler, SingleScheduler, TestScheduler, TrampolineScheduler

public abstract class Scheduler
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Scheduler.Worker

Constructor Summary

Constructors

Constructor and Description
Scheduler()

Method Summary

Modifier and Type	Method and Description
abstract Scheduler.Worker	createWorker()
long	now(java.util.concurrent.TimeUnit unit) Returns the 'current time' of the Scheduler in the specified time unit.
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.
Disposable	schedulePeriodicallyDirect(java.lang.Runnable run, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

Scheduler

public Scheduler()

Method Detail

createWorker

public abstract Scheduler.Worker createWorker()

now

public long now(java.util.concurrent.TimeUnit unit)

Returns the 'current time' of the Scheduler in the specified time unit.

Parameters:

unit - the time unit

Returns:

the 'current time'

start

public void start()

shutdown

public void shutdown()

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run)

scheduleDirect

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

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

Parameters:

run - the runnable to schedule

delay - the delay time

unit - the delay unit

Returns:

the disposable instance that can cancel the task

schedulePeriodicallyDirect

public Disposable schedulePeriodicallyDirect(java.lang.Runnable run,
                                             long initialDelay,
                                             long period,
                                             java.util.concurrent.TimeUnit unit)