Package hu.akarnokd.rxjava3.schedulers

Class ParallelScheduler

java.lang.Object

io.reactivex.rxjava3.core.Scheduler

hu.akarnokd.rxjava3.schedulers.ParallelScheduler

public final class ParallelScheduler
extends Scheduler

Scheduler with a configurable fixed amount of thread-pools.

Nested Class Summary

Nested classes/interfaces inherited from class io.reactivex.rxjava3.core.Scheduler

Scheduler.Worker

Constructor Summary

Constructors

Constructor	Description
ParallelScheduler()
ParallelScheduler(int parallelism)
ParallelScheduler(int parallelism, boolean tracking)
ParallelScheduler(int parallelism, boolean tracking, int priority)
ParallelScheduler(int parallelism, boolean tracking, int priority, java.lang.String threadNamePrefix)
ParallelScheduler(int parallelism, java.util.concurrent.ThreadFactory factory)
ParallelScheduler(int parallelism, java.util.concurrent.ThreadFactory factory, boolean tracking)
ParallelScheduler(java.lang.String threadNamePrefix)

Method Summary

Modifier and Type	Method	Description
Scheduler.Worker	createWorker()
Disposable	scheduleDirect(java.lang.Runnable run)
Disposable	scheduleDirect(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit)
Disposable	schedulePeriodicallyDirect(java.lang.Runnable run, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdown()
void	start()

Methods inherited from class io.reactivex.rxjava3.core.Scheduler

clockDriftTolerance, now, when

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelScheduler

public ParallelScheduler()

ParallelScheduler

public ParallelScheduler(java.lang.String threadNamePrefix)

ParallelScheduler

public ParallelScheduler(int parallelism)

ParallelScheduler

public ParallelScheduler(int parallelism,
                         boolean tracking)

ParallelScheduler

public ParallelScheduler(int parallelism,
                         boolean tracking,
                         int priority)

ParallelScheduler

public ParallelScheduler(int parallelism,
                         boolean tracking,
                         int priority,
                         java.lang.String threadNamePrefix)

ParallelScheduler

public ParallelScheduler(int parallelism,
                         java.util.concurrent.ThreadFactory factory)

ParallelScheduler

public ParallelScheduler(int parallelism,
                         java.util.concurrent.ThreadFactory factory,
                         boolean tracking)

Method Detail

start

public void start()

Overrides:

start in class Scheduler

shutdown

public void shutdown()

Overrides:

shutdown in class Scheduler

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)

Overrides:

scheduleDirect in class Scheduler

schedulePeriodicallyDirect

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

Overrides:

schedulePeriodicallyDirect in class Scheduler