SingleThreadSchedulerPool.java

import rx.Scheduler;
import rx.internal.util.RxThreadFactory;
import rx.schedulers.Schedulers;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;

public class SingleThreadSchedulerPool {
    private final static List<Scheduler> SCHEDULERS = new ArrayList<>();
    private final static AtomicLong COUNT = new AtomicLong(0L);

    static {
        SCHEDULERS.add(Schedulers.from(Executors.newSingleThreadExecutor(new RxThreadFactory("SingleThreadScheduler-1-"))));
        SCHEDULERS.add(Schedulers.from(Executors.newSingleThreadExecutor(new RxThreadFactory("SingleThreadScheduler-2-"))));
        SCHEDULERS.add(Schedulers.from(Executors.newSingleThreadExecutor(new RxThreadFactory("SingleThreadScheduler-3-"))));
    }

    private SingleThreadSchedulerPool() {
        // no-op
    }

    public static Scheduler get() {
        long current = COUNT.getAndIncrement();
        return SCHEDULERS.get((int) (current % 3)); // 3 is the size of SCHEDULERS
    }
}