package o.a.h.g;

import java.util.Objects;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import o.a.d;

/* JADX INFO: loaded from: classes.dex */
public final class l extends o.a.d {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final g f6084b;

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

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

    public static final class a extends d.c {

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final ScheduledExecutorService f6087f;

        /* JADX INFO: renamed from: m, reason: collision with root package name */
        public final o.a.e.a f6088m = new o.a.e.a();

        /* JADX INFO: renamed from: n, reason: collision with root package name */
        public volatile boolean f6089n;

        public a(ScheduledExecutorService scheduledExecutorService) {
            this.f6087f = scheduledExecutorService;
        }

        @Override // o.a.e.b
        public void b() {
            if (this.f6089n) {
                return;
            }
            this.f6089n = true;
            this.f6088m.b();
        }

        @Override // o.a.d.c
        public o.a.e.b d(Runnable runnable, long j2, TimeUnit timeUnit) {
            o.a.h.a.c cVar = o.a.h.a.c.INSTANCE;
            if (this.f6089n) {
                return cVar;
            }
            Objects.requireNonNull(runnable, "run is null");
            j jVar = new j(runnable, this.f6088m);
            this.f6088m.c(jVar);
            try {
                jVar.a(j2 <= 0 ? this.f6087f.submit((Callable) jVar) : this.f6087f.schedule((Callable) jVar, j2, timeUnit));
                return jVar;
            } catch (RejectedExecutionException e2) {
                b();
                g.h.a.i.P2(e2);
                return cVar;
            }
        }
    }

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

    public l() {
        g gVar = f6084b;
        AtomicReference<ScheduledExecutorService> atomicReference = new AtomicReference<>();
        this.f6086d = atomicReference;
        atomicReference.lazySet(k.a(gVar));
    }

    @Override // o.a.d
    public d.c a() {
        return new a(this.f6086d.get());
    }

    @Override // o.a.d
    public o.a.e.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        Objects.requireNonNull(runnable, "run is null");
        i iVar = new i(runnable);
        try {
            iVar.a(j2 <= 0 ? this.f6086d.get().submit(iVar) : this.f6086d.get().schedule(iVar, j2, timeUnit));
            return iVar;
        } catch (RejectedExecutionException e2) {
            g.h.a.i.P2(e2);
            return o.a.h.a.c.INSTANCE;
        }
    }

    @Override // o.a.d
    public o.a.e.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        o.a.h.a.c cVar = o.a.h.a.c.INSTANCE;
        if (j3 > 0) {
            h hVar = new h(runnable);
            try {
                hVar.a(this.f6086d.get().scheduleAtFixedRate(hVar, j2, j3, timeUnit));
                return hVar;
            } catch (RejectedExecutionException e2) {
                g.h.a.i.P2(e2);
                return cVar;
            }
        }
        ScheduledExecutorService scheduledExecutorService = this.f6086d.get();
        c cVar2 = new c(runnable, scheduledExecutorService);
        try {
            cVar2.a(j2 <= 0 ? scheduledExecutorService.submit(cVar2) : scheduledExecutorService.schedule(cVar2, j2, timeUnit));
            return cVar2;
        } catch (RejectedExecutionException e3) {
            g.h.a.i.P2(e3);
            return cVar;
        }
    }
}