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 io.reactivex.rxjava3.internal.schedulers.SchedulerMultiWorkerSupport
SchedulerMultiWorkerSupport.WorkerCallback
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final int
(package private) final ComputationScheduler.PoolWorker[]
(package private) long
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
createWorkers
(int number, SchedulerMultiWorkerSupport.WorkerCallback callback) Creates the given number ofScheduler.Worker
instances that are possibly backed by distinct threads and calls the specifiedConsumer
with them.void
shutdown()
-
Field Details
-
cores
final int cores -
eventLoops
-
n
long n
-
-
Constructor Details
-
FixedSchedulerPool
FixedSchedulerPool(int maxThreads, ThreadFactory threadFactory)
-
-
Method Details
-
getEventLoop
-
shutdown
public void shutdown() -
createWorkers
Description copied from interface:SchedulerMultiWorkerSupport
Creates the given number ofScheduler.Worker
instances that are possibly backed by distinct threads and calls the specifiedConsumer
with them.- Specified by:
createWorkers
in interfaceSchedulerMultiWorkerSupport
- Parameters:
number
- the number of workers to create, positivecallback
- the callback to send worker instances to
-