package c.a.q.g;

import c.a.g;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: SingleScheduler.java */
/* JADX INFO: loaded from: classes.dex */
public final class m extends c.a.g {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    static final h f1874b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    static final ScheduledExecutorService f1875c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    final ThreadFactory f1876d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    final AtomicReference<ScheduledExecutorService> f1877e;

    /* JADX INFO: compiled from: SingleScheduler.java */
    static final class a extends g.c {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        final ScheduledExecutorService f1878c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        final c.a.n.a f1879d = new c.a.n.a();

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        volatile boolean f1880e;

        a(ScheduledExecutorService scheduledExecutorService) {
            this.f1878c = scheduledExecutorService;
        }

        @Override // c.a.g.c
        public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
            if (this.f1880e) {
                return c.a.q.a.c.INSTANCE;
            }
            k kVar = new k(c.a.r.a.q(runnable), this.f1879d);
            this.f1879d.b(kVar);
            try {
                kVar.a(j <= 0 ? this.f1878c.submit((Callable) kVar) : this.f1878c.schedule((Callable) kVar, j, timeUnit));
                return kVar;
            } catch (RejectedExecutionException e2) {
                dispose();
                c.a.r.a.o(e2);
                return c.a.q.a.c.INSTANCE;
            }
        }

        @Override // c.a.n.b
        public void dispose() {
            if (this.f1880e) {
                return;
            }
            this.f1880e = true;
            this.f1879d.dispose();
        }
    }

    static {
        ScheduledExecutorService scheduledExecutorServiceNewScheduledThreadPool = Executors.newScheduledThreadPool(0);
        f1875c = scheduledExecutorServiceNewScheduledThreadPool;
        scheduledExecutorServiceNewScheduledThreadPool.shutdown();
        f1874b = new h("RxSingleScheduler", Math.max(1, Math.min(10, Integer.getInteger("rx2.single-priority", 5).intValue())), true);
    }

    public m() {
        this(f1874b);
    }

    static ScheduledExecutorService e(ThreadFactory threadFactory) {
        return l.a(threadFactory);
    }

    @Override // c.a.g
    public g.c a() {
        return new a(this.f1877e.get());
    }

    @Override // c.a.g
    public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
        j jVar = new j(c.a.r.a.q(runnable));
        try {
            jVar.a(j <= 0 ? this.f1877e.get().submit(jVar) : this.f1877e.get().schedule(jVar, j, timeUnit));
            return jVar;
        } catch (RejectedExecutionException e2) {
            c.a.r.a.o(e2);
            return c.a.q.a.c.INSTANCE;
        }
    }

    @Override // c.a.g
    public c.a.n.b d(Runnable runnable, long j, long j2, TimeUnit timeUnit) {
        Runnable runnableQ = c.a.r.a.q(runnable);
        if (j2 > 0) {
            i iVar = new i(runnableQ);
            try {
                iVar.a(this.f1877e.get().scheduleAtFixedRate(iVar, j, j2, timeUnit));
                return iVar;
            } catch (RejectedExecutionException e2) {
                c.a.r.a.o(e2);
                return c.a.q.a.c.INSTANCE;
            }
        }
        ScheduledExecutorService scheduledExecutorService = this.f1877e.get();
        c cVar = new c(runnableQ, scheduledExecutorService);
        try {
            cVar.b(j <= 0 ? scheduledExecutorService.submit(cVar) : scheduledExecutorService.schedule(cVar, j, timeUnit));
            return cVar;
        } catch (RejectedExecutionException e3) {
            c.a.r.a.o(e3);
            return c.a.q.a.c.INSTANCE;
        }
    }

    public m(ThreadFactory threadFactory) {
        AtomicReference<ScheduledExecutorService> atomicReference = new AtomicReference<>();
        this.f1877e = atomicReference;
        this.f1876d = threadFactory;
        atomicReference.lazySet(e(threadFactory));
    }
}