package i.a.n.g;

import i.a.h;
import java.util.concurrent.ThreadFactory;

/* JADX INFO: compiled from: NewThreadScheduler.java */
/* JADX INFO: loaded from: classes.dex */
public final class e extends i.a.h {
    private static final g c = new g("RxNewThreadScheduler", Math.max(1, Math.min(10, Integer.getInteger("rx2.newthread-priority", 5).intValue())));
    final ThreadFactory b;

    public e() {
        this(c);
    }

    @Override // i.a.h
    public h.c a() {
        return new f(this.b);
    }

    public e(ThreadFactory threadFactory) {
        this.b = threadFactory;
    }
}