Package rx.internal.schedulers
Class CachedThreadScheduler.CachedWorkerPool
java.lang.Object
rx.internal.schedulers.CachedThreadScheduler.CachedWorkerPool
- Enclosing class:
CachedThreadScheduler
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final CompositeSubscription
private final ScheduledExecutorService
private final Future
<?> private final ConcurrentLinkedQueue
<CachedThreadScheduler.ThreadWorker> private final long
private final ThreadFactory
-
Constructor Summary
ConstructorsConstructorDescriptionCachedWorkerPool
(ThreadFactory threadFactory, long keepAliveTime, TimeUnit unit) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) CachedThreadScheduler.ThreadWorker
get()
(package private) long
now()
(package private) void
release
(CachedThreadScheduler.ThreadWorker threadWorker) (package private) void
shutdown()
-
Field Details
-
threadFactory
-
keepAliveTime
private final long keepAliveTime -
expiringWorkerQueue
-
allWorkers
-
evictorService
-
evictorTask
-
-
Constructor Details
-
CachedWorkerPool
CachedWorkerPool(ThreadFactory threadFactory, long keepAliveTime, TimeUnit unit)
-
-
Method Details
-
get
-
release
-
evictExpiredWorkers
void evictExpiredWorkers() -
now
long now() -
shutdown
void shutdown()
-