Class ComputationScheduler.FixedSchedulerPool

java.lang.Object

io.reactivex.rxjava3.internal.schedulers.ComputationScheduler.FixedSchedulerPool

All Implemented Interfaces:

SchedulerMultiWorkerSupport

Enclosing class:

ComputationScheduler

static final class ComputationScheduler.FixedSchedulerPool
extends Object
implements SchedulerMultiWorkerSupport

Nested Class Summary

Nested classes/interfaces inherited from interface SchedulerMultiWorkerSupport

SchedulerMultiWorkerSupport.WorkerCallback

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	cores
(package private) final ComputationScheduler.PoolWorker[]	eventLoops
(package private) long	n

Constructor Summary

Constructors

Constructor	Description
FixedSchedulerPool(int maxThreads, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
void	createWorkers(int number, SchedulerMultiWorkerSupport.WorkerCallback callback)	Creates the given number of Scheduler.Worker instances that are possibly backed by distinct threads and calls the specified Consumer with them.
ComputationScheduler.PoolWorker	getEventLoop()
void	shutdown()

Methods inherited from class Object

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

Field Details

cores

final int cores

eventLoops

final ComputationScheduler.PoolWorker[] eventLoops

n

long n

Constructor Details

FixedSchedulerPool

FixedSchedulerPool(int maxThreads,
 ThreadFactory threadFactory)

Method Details

getEventLoop

public ComputationScheduler.PoolWorker getEventLoop()

shutdown

public void shutdown()

createWorkers

public void createWorkers(int number,
 SchedulerMultiWorkerSupport.WorkerCallback callback)

Description copied from interface: SchedulerMultiWorkerSupport

Creates the given number of Scheduler.Worker instances that are possibly backed by distinct threads and calls the specified Consumer with them.

Specified by:

createWorkers in interface SchedulerMultiWorkerSupport

Parameters:

number - the number of workers to create, positive

callback - the callback to send worker instances to