package d.a.s.g;

import d.a.m;
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;

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

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

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

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

    public static final class a extends m.c {

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

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

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

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

        @Override // d.a.m.c
        public d.a.p.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            if (this.f5894d) {
                return d.a.s.a.c.INSTANCE;
            }
            Objects.requireNonNull(runnable, "run is null");
            j jVar = new j(runnable, this.f5893c);
            this.f5893c.c(jVar);
            try {
                jVar.a(j2 <= 0 ? this.f5892b.submit((Callable) jVar) : this.f5892b.schedule((Callable) jVar, j2, timeUnit));
                return jVar;
            } catch (RejectedExecutionException e2) {
                dispose();
                d.a.u.a.w(e2);
                return d.a.s.a.c.INSTANCE;
            }
        }

        @Override // d.a.p.b
        public void dispose() {
            if (this.f5894d) {
                return;
            }
            this.f5894d = true;
            this.f5893c.dispose();
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return this.f5894d;
        }
    }

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

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

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

    @Override // d.a.m
    public d.a.p.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.f5891d.get().submit(iVar) : this.f5891d.get().schedule(iVar, j2, timeUnit));
            return iVar;
        } catch (RejectedExecutionException e2) {
            d.a.u.a.w(e2);
            return d.a.s.a.c.INSTANCE;
        }
    }

    @Override // d.a.m
    public d.a.p.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        try {
            if (j3 > 0) {
                h hVar = new h(runnable);
                hVar.a(this.f5891d.get().scheduleAtFixedRate(hVar, j2, j3, timeUnit));
                return hVar;
            }
            ScheduledExecutorService scheduledExecutorService = this.f5891d.get();
            c cVar = new c(runnable, scheduledExecutorService);
            cVar.a(j2 <= 0 ? scheduledExecutorService.submit(cVar) : scheduledExecutorService.schedule(cVar, j2, timeUnit));
            return cVar;
        } catch (RejectedExecutionException e2) {
            d.a.u.a.w(e2);
            return d.a.s.a.c.INSTANCE;
        }
    }
}