ExecutorScheduler.java 文件源码

@Override
public Subscription schedule(final Action0 action, long delayTime, TimeUnit unit) {
    if (delayTime <= 0) {
        return schedule(action);
    }
    if (isUnsubscribed()) {
        return Subscriptions.empty();
    }
    ScheduledExecutorService service;
    if (executor instanceof ScheduledExecutorService) {
        service = (ScheduledExecutorService)executor;
    } else {
        service = GenericScheduledExecutorService.getInstance();
    }

    final MultipleAssignmentSubscription mas = new MultipleAssignmentSubscription();
    // tasks.add(mas); // Needs a removal without unsubscription

    try {
        Future<?> f = service.schedule(new Runnable() {
            @Override
            public void run() {
                if (mas.isUnsubscribed()) {
                    return;
                }
                mas.set(schedule(action));
                // tasks.delete(mas); // Needs a removal without unsubscription
            }
        }, delayTime, unit);
        mas.set(Subscriptions.from(f));
    } catch (RejectedExecutionException t) {
        // report the rejection to plugins
        RxJavaPlugins.getInstance().getErrorHandler().handleError(t);
        throw t;
    }

    return mas;
}