hu.akarnokd.rxjava2.internal.schedulers

Class ComputationScheduler

java.lang.Object

hu.akarnokd.rxjava2.Scheduler

hu.akarnokd.rxjava2.internal.schedulers.ComputationScheduler

public final class ComputationScheduler
extends Scheduler

Holds a fixed pool of worker threads and assigns them to requested Scheduler.Workers in a round-robin fashion.

Nested Class Summary

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

Scheduler.Worker

Constructor Summary

Constructors

Constructor and Description
ComputationScheduler() Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

Method Summary

Modifier and Type	Method and Description
Scheduler.Worker	createWorker()
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 hu.akarnokd.rxjava2.Scheduler

now, scheduleDirect

Methods inherited from class java.lang.Object

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

Constructor Detail

ComputationScheduler

public ComputationScheduler()

Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

Method Detail

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker 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

schedulePeriodicallyDirect

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

Overrides:

schedulePeriodicallyDirect in class Scheduler

start

public void start()

Overrides:

start in class Scheduler

shutdown

public void shutdown()

Overrides:

shutdown in class Scheduler