Modifier and Type	Class and Description
pack-priv static class	EventLoopsScheduler.EventLoopWorker
pack-priv static class	EventLoopsScheduler.FixedSchedulerPool
pack-priv static class	EventLoopsScheduler.PoolWorker

Modifier and Type	Field and Description
pack-priv static final String	KEY_MAX_THREADS Key to setting the maximum number of computation scheduler threads.
pack-priv static final int	MAX_THREADS The maximum number of computation scheduler threads.
pack-priv static final EventLoopsScheduler.FixedSchedulerPool	NONE This will indicate no pool is active.
pack-priv final AtomicReference<EventLoopsScheduler.FixedSchedulerPool>	pool
pack-priv static final EventLoopsScheduler.PoolWorker	SHUTDOWN_WORKER
pack-priv final ThreadFactory	threadFactory

Access	Constructor and Description
public	EventLoopsScheduler(ThreadFactory the factory to use with the executors threadFactory) Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy.

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 Subscription	Returns: the subscription scheduleDirect(Action0 the action to schedule action) Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
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.

KEY_MAX_THREADS	back to summary
pack-priv static final String KEY_MAX_THREADS Key to setting the maximum number of computation scheduler threads. Zero or less is interpreted as use available. Capped by available.

MAX_THREADS	back to summary
pack-priv static final int MAX_THREADS The maximum number of computation scheduler threads.

NONE	back to summary
pack-priv static final EventLoopsScheduler.FixedSchedulerPool NONE This will indicate no pool is active.

pool	back to summary
pack-priv final AtomicReference<EventLoopsScheduler.FixedSchedulerPool> pool

SHUTDOWN_WORKER	back to summary
pack-priv static final EventLoopsScheduler.PoolWorker SHUTDOWN_WORKER

threadFactory	back to summary
pack-priv final ThreadFactory threadFactory

EventLoopsScheduler	back to summary
public EventLoopsScheduler(ThreadFactory threadFactory) Create a scheduler with pool size equal to the available processor count and using least-recent worker selection policy. Parameters threadFactory:ThreadFactory the factory to use with the executors

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

scheduleDirect	back to summary
public Subscription scheduleDirect(Action0 action) Schedules the action directly on one of the event loop workers without the additional infrastructure and checking. Parameters action:Action0 the action to schedule Returns:Subscription the subscription

scheduleDirect

back to summary

public Subscription scheduleDirect(Action0 action)

Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.

Parameters

action:Action0: the action to schedule

Returns:Subscription

the subscription

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 EventLoopsScheduler.EventLoopWorker

Class Inheritance

extends Worker

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

Field Summary

Modifier and Type	Field and Description
private final SubscriptionList	both
private final EventLoopsScheduler.PoolWorker	poolWorker
private final SubscriptionList	serial
private final CompositeSubscription	timed

Constructor Summary

Access	Constructor and Description
pack-priv	EventLoopWorker(EventLoopsScheduler.PoolWorker poolWorker)

Method Summary

Modifier and Type	Method and Description
public boolean	isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed.
public Subscription	schedule(final 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

both	back to summary
private final SubscriptionList both

poolWorker	back to summary
private final EventLoopsScheduler.PoolWorker poolWorker

serial	back to summary
private final SubscriptionList serial

timed	back to summary
private final CompositeSubscription timed

Constructor Detail

EventLoopWorker	back to summary
pack-priv EventLoopWorker(EventLoopsScheduler.PoolWorker poolWorker)

Method Detail

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(final 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(final 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 EventLoopsScheduler.FixedSchedulerPool

Class Inheritance

extends Object

java.lang.Object
rx.internal.schedulers.EventLoopsScheduler.FixedSchedulerPool

Field Summary

Modifier and Type	Field and Description
pack-priv final int	cores
pack-priv final EventLoopsScheduler.PoolWorker[]	eventLoops
pack-priv long	n

Constructor Summary

Access	Constructor and Description
pack-priv	FixedSchedulerPool(ThreadFactory threadFactory, int maxThreads)

Method Summary

Modifier and Type	Method and Description
public EventLoopsScheduler.PoolWorker	getEventLoop()
public void	shutdown()

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

Field Detail

cores	back to summary
pack-priv final int cores

eventLoops	back to summary
pack-priv final EventLoopsScheduler.PoolWorker[] eventLoops

n	back to summary
pack-priv long n

Constructor Detail

FixedSchedulerPool	back to summary
pack-priv FixedSchedulerPool(ThreadFactory threadFactory, int maxThreads)

Method Detail

getEventLoop	back to summary
public EventLoopsScheduler.PoolWorker getEventLoop()

shutdown	back to summary
public void shutdown()

public final Class EventLoopsScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class EventLoopsScheduler.EventLoopWorker

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class EventLoopsScheduler.FixedSchedulerPool

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class EventLoopsScheduler.PoolWorker

Field Summary

Constructor Summary

Method Summary

Constructor Detail