public class CoreScheduler extends rx.Scheduler implements ShutdownHook
The Core scheduler which is modeled after the Event Loops Scheduler (which is package private).
Constructor and Description |
---|
CoreScheduler(int poolSize)
Create a scheduler with specified pool size and using least-recent worker selection policy.
|
Modifier and Type | Method and Description |
---|---|
rx.Scheduler.Worker |
createWorker() |
boolean |
isShutdown() |
rx.Subscription |
scheduleDirect(rx.functions.Action0 action)
Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
|
rx.Observable<Boolean> |
shutdown() |
void |
start() |
public CoreScheduler(int poolSize)
Create a scheduler with specified pool size and using least-recent worker selection policy.
public void start()
public rx.Observable<Boolean> shutdown()
shutdown
in interface ShutdownHook
public boolean isShutdown()
isShutdown
in interface ShutdownHook
public rx.Scheduler.Worker createWorker()
createWorker
in class rx.Scheduler
public rx.Subscription scheduleDirect(rx.functions.Action0 action)
Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
action
- the action to scheduleCopyright © 2018 Couchbase, Inc.. All rights reserved.