public class CoreScheduler extends Scheduler implements ShutdownHook
The Core scheduler which is modeled after the Event Loops Scheduler (which is package private).
Scheduler.Worker
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 |
---|---|
Scheduler.Worker |
createWorker() |
boolean |
isShutdown() |
Subscription |
scheduleDirect(Action0 action)
Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
|
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 Observable<Boolean> shutdown()
shutdown
in interface ShutdownHook
public boolean isShutdown()
isShutdown
in interface ShutdownHook
public Scheduler.Worker createWorker()
createWorker
in class Scheduler
public Subscription scheduleDirect(Action0 action)
Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
action
- the action to scheduleCopyright © 2017 Couchbase, Inc.. All rights reserved.