package d.a.s.g;

import d.a.m;
import java.util.Objects;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

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

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

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static final int f5836d;

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

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final AtomicReference<C0081b> f5839g;

    public static final class a extends m.c {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final d.a.s.a.d f5840b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public final d.a.p.a f5841c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public final d.a.s.a.d f5842d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final c f5843e;

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

        public a(c cVar) {
            this.f5843e = cVar;
            d.a.s.a.d dVar = new d.a.s.a.d();
            this.f5840b = dVar;
            d.a.p.a aVar = new d.a.p.a();
            this.f5841c = aVar;
            d.a.s.a.d dVar2 = new d.a.s.a.d();
            this.f5842d = dVar2;
            dVar2.c(dVar);
            dVar2.c(aVar);
        }

        @Override // d.a.m.c
        public d.a.p.b b(Runnable runnable) {
            return this.f5844f ? d.a.s.a.c.INSTANCE : this.f5843e.e(runnable, 0L, TimeUnit.MILLISECONDS, this.f5840b);
        }

        @Override // d.a.m.c
        public d.a.p.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            return this.f5844f ? d.a.s.a.c.INSTANCE : this.f5843e.e(runnable, j2, timeUnit, this.f5841c);
        }

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

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

    /* JADX INFO: renamed from: d.a.s.g.b$b, reason: collision with other inner class name */
    public static final class C0081b {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        public final int f5845a;

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final c[] f5846b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public long f5847c;

        public C0081b(int i2, ThreadFactory threadFactory) {
            this.f5845a = i2;
            this.f5846b = new c[i2];
            for (int i3 = 0; i3 < i2; i3++) {
                this.f5846b[i3] = new c(threadFactory);
            }
        }

        public c a() {
            int i2 = this.f5845a;
            if (i2 == 0) {
                return b.f5837e;
            }
            c[] cVarArr = this.f5846b;
            long j2 = this.f5847c;
            this.f5847c = 1 + j2;
            return cVarArr[(int) (j2 % ((long) i2))];
        }
    }

    public static final class c extends f {
        public c(ThreadFactory threadFactory) {
            super(threadFactory);
        }
    }

    static {
        int iAvailableProcessors = Runtime.getRuntime().availableProcessors();
        int iIntValue = Integer.getInteger("rx2.computation-threads", 0).intValue();
        if (iIntValue > 0 && iIntValue <= iAvailableProcessors) {
            iAvailableProcessors = iIntValue;
        }
        f5836d = iAvailableProcessors;
        c cVar = new c(new g("RxComputationShutdown"));
        f5837e = cVar;
        cVar.dispose();
        g gVar = new g("RxComputationThreadPool", Math.max(1, Math.min(10, Integer.getInteger("rx2.computation-priority", 5).intValue())), true);
        f5835c = gVar;
        C0081b c0081b = new C0081b(0, gVar);
        f5834b = c0081b;
        for (c cVar2 : c0081b.f5846b) {
            cVar2.dispose();
        }
    }

    public b() {
        g gVar = f5835c;
        this.f5838f = gVar;
        C0081b c0081b = f5834b;
        AtomicReference<C0081b> atomicReference = new AtomicReference<>(c0081b);
        this.f5839g = atomicReference;
        C0081b c0081b2 = new C0081b(f5836d, gVar);
        if (atomicReference.compareAndSet(c0081b, c0081b2)) {
            return;
        }
        for (c cVar : c0081b2.f5846b) {
            cVar.dispose();
        }
    }

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

    @Override // d.a.m
    public d.a.p.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        c cVarA = this.f5839g.get().a();
        Objects.requireNonNull(cVarA);
        Objects.requireNonNull(runnable, "run is null");
        i iVar = new i(runnable);
        try {
            iVar.a(j2 <= 0 ? cVarA.f5875b.submit(iVar) : cVarA.f5875b.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) {
        c cVarA = this.f5839g.get().a();
        Objects.requireNonNull(cVarA);
        try {
            if (j3 <= 0) {
                d.a.s.g.c cVar = new d.a.s.g.c(runnable, cVarA.f5875b);
                cVar.a(j2 <= 0 ? cVarA.f5875b.submit(cVar) : cVarA.f5875b.schedule(cVar, j2, timeUnit));
                return cVar;
            }
            h hVar = new h(runnable);
            hVar.a(cVarA.f5875b.scheduleAtFixedRate(hVar, j2, j3, timeUnit));
            return hVar;
        } catch (RejectedExecutionException e2) {
            d.a.u.a.w(e2);
            return d.a.s.a.c.INSTANCE;
        }
    }
}