Class IoScheduler.CachedWorkerPool

java.lang.Object

io.reactivex.rxjava3.internal.schedulers.IoScheduler.CachedWorkerPool

All Implemented Interfaces:

Runnable

Enclosing class:

IoScheduler

static final class IoScheduler.CachedWorkerPool
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final CompositeDisposable	allWorkers
private final ScheduledExecutorService	evictorService
private final Future<?>	evictorTask
private final ConcurrentLinkedQueue<IoScheduler.ThreadWorker>	expiringWorkerQueue
private final long	keepAliveTime
private final ThreadFactory	threadFactory

Constructor Summary

Constructors

Constructor	Description
CachedWorkerPool(long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
(package private) static void	evictExpiredWorkers(ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue, CompositeDisposable allWorkers)
(package private) IoScheduler.ThreadWorker	get()
(package private) static long	now()
(package private) void	release(IoScheduler.ThreadWorker threadWorker)
void	run()
(package private) void	shutdown()

Methods inherited from class Object

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

Field Details

keepAliveTime

private final long keepAliveTime

expiringWorkerQueue

private final ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue

allWorkers

final CompositeDisposable allWorkers

evictorService

private final ScheduledExecutorService evictorService

evictorTask

private final Future<?> evictorTask

threadFactory

private final ThreadFactory threadFactory

Constructor Details

CachedWorkerPool

CachedWorkerPool(long keepAliveTime,
 TimeUnit unit,
 ThreadFactory threadFactory)

Method Details

run

public void run()

Specified by:

run in interface Runnable

get

IoScheduler.ThreadWorker get()

release

void release(IoScheduler.ThreadWorker threadWorker)

evictExpiredWorkers

static void evictExpiredWorkers(ConcurrentLinkedQueue<IoScheduler.ThreadWorker> expiringWorkerQueue,
 CompositeDisposable allWorkers)

now

static long now()

shutdown

void shutdown()