Package rx.internal.schedulers
Class CachedThreadScheduler.ThreadWorker
- java.lang.Object
-
- rx.Scheduler.Worker
-
- rx.internal.schedulers.NewThreadWorker
-
- rx.internal.schedulers.CachedThreadScheduler.ThreadWorker
-
- All Implemented Interfaces:
Subscription
- Enclosing class:
- CachedThreadScheduler
static final class CachedThreadScheduler.ThreadWorker extends NewThreadWorker
-
-
Field Summary
Fields Modifier and Type Field Description private long
expirationTime
-
Fields inherited from class rx.internal.schedulers.NewThreadWorker
isUnsubscribed, PURGE_FREQUENCY
-
-
Constructor Summary
Constructors Constructor Description ThreadWorker(java.util.concurrent.ThreadFactory threadFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getExpirationTime()
void
setExpirationTime(long expirationTime)
-
Methods inherited from class rx.internal.schedulers.NewThreadWorker
deregisterExecutor, findSetRemoveOnCancelPolicyMethod, isUnsubscribed, purgeExecutors, registerExecutor, schedule, schedule, scheduleActual, scheduleActual, scheduleActual, tryEnableCancelPolicy, unsubscribe
-
Methods inherited from class rx.Scheduler.Worker
now, schedulePeriodically
-
-