io.reactivex.schedulers.Schedulers#computation ( )源码实例Demo

public static Scheduler cast(ThreadMode threadMode) {
    Scheduler scheduler = null;
    switch (threadMode) {
        case COMPUTATION:
            scheduler = Schedulers.computation();
            break;
        case NEWTHREAD:
            scheduler = Schedulers.newThread();
            break;
        case MAIN:
            scheduler = AndroidSchedulers.mainThread();
            break;
        case IO:
            scheduler = Schedulers.io();
            break;
        default:
            scheduler = AndroidSchedulers.mainThread();
            break;
    }
    return scheduler;
}
 

private void demo0() {
    Schedulers.single();
    Schedulers.trampoline();
    Schedulers.newThread();
    Schedulers.computation();
    Schedulers.io();
    Schedulers.io();
}
 

private void demo0() {
    Schedulers.single();
    Schedulers.trampoline();
    Schedulers.newThread();
    Schedulers.computation();
    Schedulers.io();
    Schedulers.io();
}
 

@NonNull
@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Override
@NonNull
public Scheduler computation() {
  return Schedulers.computation();
}
 

@NonNull
@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Provides
@Singleton
@Named("compute")
public Scheduler providesComputeScheduler() {
  return Schedulers.computation();
}
 

@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

/**
 * Computation thread pool scheduler
 */
public Scheduler computation() {
    return Schedulers.computation();
}
 

public static Scheduler computationScheduler() {
    if (sComputationScheduler != null) {
        return sComputationScheduler;
    }
    return Schedulers.computation();
}
 

@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

@NonNull
public Scheduler computation() {
  return Schedulers.computation();
}
 

@Override
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Provides
@Singleton
@Named(JOB)
public Scheduler provideJobScheduler() {
    return Schedulers.computation();
}
 

@Override
@NonNull
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Override
@NonNull
public Scheduler computation() {
    return Schedulers.computation();
}
 

@Override
@NonNull
public Scheduler computation() {
    return Schedulers.computation();
}
 

/**
 * Provides the computation thread Scheduler.
 *
 * @return provides the computation thread Scheduler.
 */
@Override
public Scheduler provideComputationScheduler() {
    return Schedulers.computation();
}
 

/**
 * Provides the computation thread Scheduler.
 *
 * @return provides the computation thread Scheduler.
 */
@Override
public Scheduler provideComputationScheduler() {
    return Schedulers.computation();
}