hu.akarnokd.rxjava2.internal.schedulers

Class IOScheduler

java.lang.Object

hu.akarnokd.rxjava2.Scheduler

hu.akarnokd.rxjava2.internal.schedulers.IOScheduler

All Implemented Interfaces:

SchedulerLifecycle

public final class IOScheduler
extends Scheduler
implements SchedulerLifecycle

Scheduler that creates and caches a set of thread pools and reuses them if possible.

Nested Class Summary

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

Scheduler.Worker

Constructor Summary

Constructors

Constructor and Description
IOScheduler()

Method Summary

Modifier and Type	Method and Description
Scheduler.Worker	createWorker()
void	shutdown()
int	size()
void	start()

Methods inherited from class hu.akarnokd.rxjava2.Scheduler

now, scheduleDirect, scheduleDirect, schedulePeriodicallyDirect

Methods inherited from class java.lang.Object

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

Constructor Detail

IOScheduler

public IOScheduler()

Method Detail

start

public void start()

Specified by:

start in interface SchedulerLifecycle

Overrides:

start in class Scheduler

shutdown

public void shutdown()

Specified by:

shutdown in interface SchedulerLifecycle

Overrides:

shutdown in class Scheduler

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker in class Scheduler

size

public int size()