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 C0083b f5819b;

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

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

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

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

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

    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 f5825b;

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

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

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

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

        public a(c cVar) {
            this.f5828e = cVar;
            d.a.s.a.d dVar = new d.a.s.a.d();
            this.f5825b = dVar;
            d.a.p.a aVar = new d.a.p.a();
            this.f5826c = aVar;
            d.a.s.a.d dVar2 = new d.a.s.a.d();
            this.f5827d = dVar2;
            dVar2.c(dVar);
            dVar2.c(aVar);
        }

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

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

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

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

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

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

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

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

        public C0083b(int i2, ThreadFactory threadFactory) {
            this.f5830a = i2;
            this.f5831b = new c[i2];
            for (int i3 = 0; i3 < i2; i3++) {
                this.f5831b[i3] = new c(threadFactory);
            }
        }

        public c a() {
            int i2 = this.f5830a;
            if (i2 == 0) {
                return b.f5822e;
            }
            c[] cVarArr = this.f5831b;
            long j2 = this.f5832c;
            this.f5832c = 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;
        }
        f5821d = iAvailableProcessors;
        c cVar = new c(new g("RxComputationShutdown"));
        f5822e = cVar;
        cVar.dispose();
        g gVar = new g("RxComputationThreadPool", Math.max(1, Math.min(10, Integer.getInteger("rx2.computation-priority", 5).intValue())), true);
        f5820c = gVar;
        C0083b c0083b = new C0083b(0, gVar);
        f5819b = c0083b;
        for (c cVar2 : c0083b.f5831b) {
            cVar2.dispose();
        }
    }

    public b() {
        g gVar = f5820c;
        this.f5823f = gVar;
        C0083b c0083b = f5819b;
        AtomicReference<C0083b> atomicReference = new AtomicReference<>(c0083b);
        this.f5824g = atomicReference;
        C0083b c0083b2 = new C0083b(f5821d, gVar);
        if (atomicReference.compareAndSet(c0083b, c0083b2)) {
            return;
        }
        for (c cVar : c0083b2.f5831b) {
            cVar.dispose();
        }
    }

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

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