Package rx.internal.schedulers

Class CachedThreadScheduler.CachedWorkerPool

java.lang.Object

rx.internal.schedulers.CachedThreadScheduler.CachedWorkerPool

Enclosing class:

CachedThreadScheduler

static final class CachedThreadScheduler.CachedWorkerPool
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final CompositeSubscription	allWorkers
private final ScheduledExecutorService	evictorService
private final Future<?>	evictorTask
private final ConcurrentLinkedQueue<CachedThreadScheduler.ThreadWorker>	expiringWorkerQueue
private final long	keepAliveTime
private final ThreadFactory	threadFactory

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) void	evictExpiredWorkers()
(package private) CachedThreadScheduler.ThreadWorker	get()
(package private) long	now()
(package private) void	release(CachedThreadScheduler.ThreadWorker threadWorker)
(package private) void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

threadFactory

private final ThreadFactory threadFactory

keepAliveTime

private final long keepAliveTime

expiringWorkerQueue

private final ConcurrentLinkedQueue<CachedThreadScheduler.ThreadWorker> expiringWorkerQueue

allWorkers

private final CompositeSubscription allWorkers

evictorService

private final ScheduledExecutorService evictorService

evictorTask

private final Future<?> evictorTask

Constructor Details

CachedWorkerPool

CachedWorkerPool(ThreadFactory threadFactory,
 long keepAliveTime,
 TimeUnit unit)

Method Details

get

CachedThreadScheduler.ThreadWorker get()

release

void release(CachedThreadScheduler.ThreadWorker threadWorker)

evictExpiredWorkers

void evictExpiredWorkers()

now

long now()

shutdown

void shutdown()