Java 类io.reactivex.internal.schedulers.RxThreadFactory 实例源码

@Test
public void constructors() {
    startStop(new ParallelScheduler());
    startStop(new ParallelScheduler(1));
    startStop(new ParallelScheduler(1, new RxThreadFactory("Test")));
    startStop(new ParallelScheduler("Test"));
}

public WeakParallelScheduler(int parallelism) {
    ExecutorService[] execs = new ExecutorService[parallelism];

    for (int i = 0; i < parallelism; i++) {
        execs[i] = Executors.newSingleThreadExecutor(new RxThreadFactory("RxWeakParallelScheduler"));
    }

    executors = execs;
}

public ParallelScheduler(String threadNamePrefix) {
    this(Runtime.getRuntime().availableProcessors(), new RxThreadFactory(threadNamePrefix));
}

public ParallelScheduler(int parallelism, boolean tracking, int priority, String threadNamePrefix) {
    this(parallelism, new RxThreadFactory(threadNamePrefix, checkPriority(priority)), tracking);
}