Modifier and Type	Class and Description
pack-priv static class	CachedThreadScheduler.CachedWorkerPool
pack-priv static class	CachedThreadScheduler.EventLoopWorker
pack-priv static class	CachedThreadScheduler.ThreadWorker

Modifier and Type	Field and Description
private static final long	KEEP_ALIVE_TIME
private static final TimeUnit	KEEP_ALIVE_UNIT
pack-priv static final CachedThreadScheduler.CachedWorkerPool	NONE
pack-priv final AtomicReference<CachedThreadScheduler.CachedWorkerPool>	pool
pack-priv static final CachedThreadScheduler.ThreadWorker	SHUTDOWN_THREADWORKER
pack-priv final ThreadFactory	threadFactory

Access	Constructor and Description
public	CachedThreadScheduler(ThreadFactory threadFactory)

Modifier and Type	Method and Description
public Scheduler.Worker	createWorker() Implements abstract rx.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents serial execution of actions.
public void	shutdown() Implements rx.internal.schedulers.SchedulerLifecycle.shutdown. Instructs the Scheduler instance to stop threads and stop accepting tasks on any outstanding Workers.
public void	start() Implements rx.internal.schedulers.SchedulerLifecycle.start. Allows the Scheduler instance to start threads and accept tasks on them.

KEEP_ALIVE_TIME	back to summary
private static final long KEEP_ALIVE_TIME

KEEP_ALIVE_UNIT	back to summary
private static final TimeUnit KEEP_ALIVE_UNIT

NONE	back to summary
pack-priv static final CachedThreadScheduler.CachedWorkerPool NONE

pool	back to summary
pack-priv final AtomicReference<CachedThreadScheduler.CachedWorkerPool> pool

SHUTDOWN_THREADWORKER	back to summary
pack-priv static final CachedThreadScheduler.ThreadWorker SHUTDOWN_THREADWORKER

threadFactory	back to summary
pack-priv final ThreadFactory threadFactory

CachedThreadScheduler	back to summary
public CachedThreadScheduler(ThreadFactory threadFactory)

Method Detail

createWorker back to summary

createWorker	back to summary
public Scheduler.Worker createWorker() Implements abstract rx.Scheduler.createWorker. Doc from rx.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents serial execution of actions. When work is completed it should be unsubscribed using `Scheduler.Worker#unsubscribe()`. Work on a `Scheduler.Worker` is guaranteed to be sequential. Returns:Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @Override

public Scheduler.Worker createWorker()

Implements abstract rx.Scheduler.createWorker.

Doc from rx.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.

When work is completed it should be unsubscribed using Scheduler.Worker#unsubscribe().

Work on a Scheduler.Worker is guaranteed to be sequential.

Returns:Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations

@Override

shutdown	back to summary
public void shutdown() Implements rx.internal.schedulers.SchedulerLifecycle.shutdown. Doc from rx.internal.schedulers.SchedulerLifecycle.shutdown. Instructs the Scheduler instance to stop threads and stop accepting tasks on any outstanding Workers. Implementations should make sure the call is idempotent and thread-safe. Annotations @Override

shutdown

back to summary

public void shutdown()

Implements rx.internal.schedulers.SchedulerLifecycle.shutdown.

Doc from rx.internal.schedulers.SchedulerLifecycle.shutdown.

Instructs the Scheduler instance to stop threads and stop accepting tasks on any outstanding Workers.

Implementations should make sure the call is idempotent and thread-safe.

Annotations

@Override

start	back to summary
public void start() Implements rx.internal.schedulers.SchedulerLifecycle.start. Doc from rx.internal.schedulers.SchedulerLifecycle.start. Allows the Scheduler instance to start threads and accept tasks on them. Implementations should make sure the call is idempotent and thread-safe. Annotations @Override

start

back to summary

public void start()

Implements rx.internal.schedulers.SchedulerLifecycle.start.

Doc from rx.internal.schedulers.SchedulerLifecycle.start.

Allows the Scheduler instance to start threads and accept tasks on them.

Implementations should make sure the call is idempotent and thread-safe.

Annotations

@Override

rx.internal.schedulers back to summary

pack-priv final Class CachedThreadScheduler.CachedWorkerPool

Class Inheritance

extends Object

java.lang.Object
rx.internal.schedulers.CachedThreadScheduler.CachedWorkerPool

Field Summary

Modifier and Type	Field and 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

Access	Constructor and Description
pack-priv	CachedWorkerPool(final ThreadFactory threadFactory, long keepAliveTime, TimeUnit unit)

Method Summary

Modifier and Type	Method and Description
pack-priv void	evictExpiredWorkers()
pack-priv CachedThreadScheduler.ThreadWorker	get()
pack-priv long	now()
pack-priv void	release(CachedThreadScheduler.ThreadWorker threadWorker)
pack-priv void	shutdown()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allWorkers	back to summary
private final CompositeSubscription allWorkers

evictorService	back to summary
private final ScheduledExecutorService evictorService

evictorTask	back to summary
private final Future<?> evictorTask

expiringWorkerQueue	back to summary
private final ConcurrentLinkedQueue<CachedThreadScheduler.ThreadWorker> expiringWorkerQueue

keepAliveTime	back to summary
private final long keepAliveTime

threadFactory	back to summary
private final ThreadFactory threadFactory

Constructor Detail

CachedWorkerPool	back to summary
pack-priv CachedWorkerPool(final ThreadFactory threadFactory, long keepAliveTime, TimeUnit unit)

Method Detail

evictExpiredWorkers	back to summary
pack-priv void evictExpiredWorkers()

get	back to summary
pack-priv CachedThreadScheduler.ThreadWorker get()

now	back to summary
pack-priv long now()

release	back to summary
pack-priv void release(CachedThreadScheduler.ThreadWorker threadWorker)

shutdown	back to summary
pack-priv void shutdown()

rx.internal.schedulers back to summary

pack-priv final Class CachedThreadScheduler.EventLoopWorker

Class Inheritance

extends Worker
implements Action0

java.lang.Object
rx.Scheduler.Worker
rx.internal.schedulers.CachedThreadScheduler.EventLoopWorker

All Implemented Interfaces

rx.functions.Action0, rx.functions.Action, rx.functions.Function

Field Summary

Modifier and Type	Field and Description
private final CompositeSubscription	innerSubscription
pack-priv final AtomicBoolean	once
private final CachedThreadScheduler.CachedWorkerPool	pool
private final CachedThreadScheduler.ThreadWorker	threadWorker

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoopWorker(CachedThreadScheduler.CachedWorkerPool pool)

Method Summary

Modifier and Type	Method and Description
public void	call() Implements rx.functions.Action0.call.
public boolean	isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed.
public Subscription	schedule(Action0 Action to schedule action) Implements abstract rx.Scheduler.Worker.schedule. Schedules an Action for execution.
public Subscription	schedule(final Action0 the Action to schedule action, long time to wait before executing the action; non-positive values indicate an non-delayed schedule delayTime, TimeUnit the time unit of `delayTime` unit) Implements abstract rx.Scheduler.Worker.schedule. Schedules an Action for execution at some point in the future.
public void	unsubscribe() Implements rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received.

Inherited from rx.Scheduler.Worker:: now schedulePeriodically

Field Detail

innerSubscription	back to summary
private final CompositeSubscription innerSubscription

once	back to summary
pack-priv final AtomicBoolean once

pool	back to summary
private final CachedThreadScheduler.CachedWorkerPool pool

threadWorker	back to summary
private final CachedThreadScheduler.ThreadWorker threadWorker

Constructor Detail

EventLoopWorker	back to summary
pack-priv EventLoopWorker(CachedThreadScheduler.CachedWorkerPool pool)

Method Detail

call	back to summary
public void call() Implements rx.functions.Action0.call. Annotations @Override

call

back to summary

public void call()

Implements rx.functions.Action0.call.

Annotations

@Override

isUnsubscribed back to summary

isUnsubscribed	back to summary
public boolean isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Doc from rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed. Returns:boolean `true` if this `Subscription` is currently unsubscribed, `false` otherwise Annotations @Override

public boolean isUnsubscribed()

Implements rx.Subscription.isUnsubscribed.

Doc from rx.Subscription.isUnsubscribed.

Indicates whether this Subscription is currently unsubscribed.

Returns:boolean

true if this Subscription is currently unsubscribed, false otherwise

Annotations

@Override

schedule	back to summary
public Subscription schedule(Action0 action) Implements abstract rx.Scheduler.Worker.schedule. Doc from rx.Scheduler.Worker.schedule. Schedules an Action for execution. Parameters action:Action0 Action to schedule Returns:Subscription a subscription to be able to prevent or cancel the execution of the action Annotations @Override

schedule

back to summary

public Subscription schedule(Action0 action)

Implements abstract rx.Scheduler.Worker.schedule.

Doc from rx.Scheduler.Worker.schedule.

Schedules an Action for execution.

Parameters

action:Action0: Action to schedule

Returns:Subscription

a subscription to be able to prevent or cancel the execution of the action

Annotations

@Override

schedule back to summary

schedule	back to summary
public Subscription schedule(final Action0 action, long delayTime, TimeUnit unit) Implements abstract rx.Scheduler.Worker.schedule. Doc from rx.Scheduler.Worker.schedule. Schedules an Action for execution at some point in the future. Note to implementors: non-positive `delayTime` should be regarded as non-delayed schedule, i.e., as if the `schedule(rx.functions.Action0)` was called. Parameters action:Action0 the Action to schedule delayTime:long time to wait before executing the action; non-positive values indicate an non-delayed schedule unit:TimeUnit the time unit of `delayTime` Returns:Subscription a subscription to be able to prevent or cancel the execution of the action Annotations @Override

public Subscription schedule(final Action0 action, long delayTime, TimeUnit unit)

Implements abstract rx.Scheduler.Worker.schedule.

Doc from rx.Scheduler.Worker.schedule.

Schedules an Action for execution at some point in the future.

Note to implementors: non-positive delayTime should be regarded as non-delayed schedule, i.e., as if the schedule(rx.functions.Action0) was called.

Parameters

action:Action0: the Action to schedule
delayTime:long: time to wait before executing the action; non-positive values indicate an non-delayed schedule
unit:TimeUnit: the time unit of delayTime

Returns:Subscription

a subscription to be able to prevent or cancel the execution of the action

Annotations

@Override

unsubscribe back to summary

unsubscribe	back to summary
public void unsubscribe() Implements rx.Subscription.unsubscribe. Doc from rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received. This allows deregistering an `Subscriber` before it has finished receiving all events (i.e. before onCompleted is called). Annotations @Override

public void unsubscribe()

Implements rx.Subscription.unsubscribe.

Doc from rx.Subscription.unsubscribe.

Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

This allows deregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

Annotations

@Override

rx.internal.schedulers back to summary

pack-priv final Class CachedThreadScheduler.ThreadWorker

Class Inheritance

extends NewThreadWorker

java.lang.Object
rx.Scheduler.Worker
rx.internal.schedulers.NewThreadWorker
rx.internal.schedulers.CachedThreadScheduler.ThreadWorker

Field Summary

Modifier and Type	Field and Description
private long	expirationTime

Inherited from rx.internal.schedulers.NewThreadWorker:: isUnsubscribed PURGE_FREQUENCY

Constructor Summary

Access	Constructor and Description
pack-priv	ThreadWorker(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
public long	getExpirationTime()
public void	setExpirationTime(long expirationTime)

Inherited from rx.internal.schedulers.NewThreadWorker:: deregisterExecutor findSetRemoveOnCancelPolicyMethod isUnsubscribed purgeExecutors registerExecutor schedule schedule scheduleActual scheduleActual scheduleActual tryEnableCancelPolicy unsubscribe

Field Detail

expirationTime	back to summary
private long expirationTime

Constructor Detail

ThreadWorker	back to summary
pack-priv ThreadWorker(ThreadFactory threadFactory)

Method Detail

getExpirationTime	back to summary
public long getExpirationTime()

setExpirationTime	back to summary
public void setExpirationTime(long expirationTime)

public final Class CachedThreadScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class CachedThreadScheduler.CachedWorkerPool

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class CachedThreadScheduler.EventLoopWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class CachedThreadScheduler.ThreadWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail