package e.a.u.g;

import e.a.n;
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 k extends n {

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final e.a.r.a f3840f = new e.a.r.a();

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

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

        @Override // e.a.n.c
        public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            if (this.f3841g) {
                return e.a.u.a.c.INSTANCE;
            }
            i iVar = new i(e.a.w.a.s(runnable), this.f3840f);
            this.f3840f.c(iVar);
            try {
                iVar.a(j2 <= 0 ? this.f3839b.submit((Callable) iVar) : this.f3839b.schedule((Callable) iVar, j2, timeUnit));
                return iVar;
            } catch (RejectedExecutionException e2) {
                dispose();
                e.a.w.a.p(e2);
                return e.a.u.a.c.INSTANCE;
            }
        }

        @Override // e.a.r.b
        public void dispose() {
            if (this.f3841g) {
                return;
            }
            this.f3841g = true;
            this.f3840f.dispose();
        }

        @Override // e.a.r.b
        public boolean isDisposed() {
            return this.f3841g;
        }
    }

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

    public k() {
        this(f3836c);
    }

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

    @Override // e.a.n
    public n.c a() {
        return new a(this.f3838b.get());
    }

    @Override // e.a.n
    public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        h hVar = new h(e.a.w.a.s(runnable));
        try {
            hVar.a(j2 <= 0 ? this.f3838b.get().submit(hVar) : this.f3838b.get().schedule(hVar, j2, timeUnit));
            return hVar;
        } catch (RejectedExecutionException e2) {
            e.a.w.a.p(e2);
            return e.a.u.a.c.INSTANCE;
        }
    }

    @Override // e.a.n
    public e.a.r.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        g gVar = new g(e.a.w.a.s(runnable));
        try {
            gVar.a(this.f3838b.get().scheduleAtFixedRate(gVar, j2, j3, timeUnit));
            return gVar;
        } catch (RejectedExecutionException e2) {
            e.a.w.a.p(e2);
            return e.a.u.a.c.INSTANCE;
        }
    }

    public k(ThreadFactory threadFactory) {
        AtomicReference<ScheduledExecutorService> atomicReference = new AtomicReference<>();
        this.f3838b = atomicReference;
        atomicReference.lazySet(e(threadFactory));
    }
}