package f.a.w.g;

import f.a.o;
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: compiled from: ComputationScheduler.java */
/* JADX INFO: loaded from: classes.dex */
public final class b extends f.a.o {

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

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

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

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

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

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

    /* JADX INFO: compiled from: ComputationScheduler.java */
    public static final class a extends o.c {

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final f.a.t.a f3949e;

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

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

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

        public a(c cVar) {
            this.f3951g = cVar;
            f.a.w.a.d dVar = new f.a.w.a.d();
            this.f3948b = dVar;
            f.a.t.a aVar = new f.a.t.a();
            this.f3949e = aVar;
            f.a.w.a.d dVar2 = new f.a.w.a.d();
            this.f3950f = dVar2;
            dVar2.b(dVar);
            dVar2.b(aVar);
        }

        @Override // f.a.o.c
        public f.a.t.b b(Runnable runnable) {
            return this.f3952h ? f.a.w.a.c.INSTANCE : this.f3951g.e(runnable, 0L, TimeUnit.MILLISECONDS, this.f3948b);
        }

        @Override // f.a.o.c
        public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            return this.f3952h ? f.a.w.a.c.INSTANCE : this.f3951g.e(runnable, j2, timeUnit, this.f3949e);
        }

        @Override // f.a.t.b
        public void dispose() {
            if (this.f3952h) {
                return;
            }
            this.f3952h = true;
            this.f3950f.dispose();
        }
    }

    /* JADX INFO: renamed from: f.a.w.g.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: ComputationScheduler.java */
    public static final class C0071b {
        public final int a;

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

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

        public C0071b(int i2, ThreadFactory threadFactory) {
            this.a = i2;
            this.f3953b = new c[i2];
            for (int i3 = 0; i3 < i2; i3++) {
                this.f3953b[i3] = new c(threadFactory);
            }
        }

        public c a() {
            int i2 = this.a;
            if (i2 == 0) {
                return b.f3945e;
            }
            c[] cVarArr = this.f3953b;
            long j2 = this.f3954c;
            this.f3954c = 1 + j2;
            return cVarArr[(int) (j2 % ((long) i2))];
        }
    }

    /* JADX INFO: compiled from: ComputationScheduler.java */
    public static final class c extends h {
        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;
        }
        f3944d = iAvailableProcessors;
        c cVar = new c(new i("RxComputationShutdown"));
        f3945e = cVar;
        cVar.dispose();
        i iVar = new i("RxComputationThreadPool", Math.max(1, Math.min(10, Integer.getInteger("rx2.computation-priority", 5).intValue())), true);
        f3943c = iVar;
        C0071b c0071b = new C0071b(0, iVar);
        f3942b = c0071b;
        for (c cVar2 : c0071b.f3953b) {
            cVar2.dispose();
        }
    }

    public b() {
        i iVar = f3943c;
        this.f3946f = iVar;
        C0071b c0071b = f3942b;
        AtomicReference<C0071b> atomicReference = new AtomicReference<>(c0071b);
        this.f3947g = atomicReference;
        C0071b c0071b2 = new C0071b(f3944d, iVar);
        if (atomicReference.compareAndSet(c0071b, c0071b2)) {
            return;
        }
        for (c cVar : c0071b2.f3953b) {
            cVar.dispose();
        }
    }

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

    @Override // f.a.o
    public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        c cVarA = this.f3947g.get().a();
        Objects.requireNonNull(cVarA);
        Objects.requireNonNull(runnable, "run is null");
        k kVar = new k(runnable);
        try {
            kVar.a(j2 <= 0 ? cVarA.f4002b.submit(kVar) : cVarA.f4002b.schedule(kVar, j2, timeUnit));
            return kVar;
        } catch (RejectedExecutionException e2) {
            f.a.y.a.C0(e2);
            return f.a.w.a.c.INSTANCE;
        }
    }

    @Override // f.a.o
    public f.a.t.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        c cVarA = this.f3947g.get().a();
        Objects.requireNonNull(cVarA);
        if (j3 <= 0) {
            e eVar = new e(runnable, cVarA.f4002b);
            try {
                eVar.a(j2 <= 0 ? cVarA.f4002b.submit(eVar) : cVarA.f4002b.schedule(eVar, j2, timeUnit));
                return eVar;
            } catch (RejectedExecutionException e2) {
                f.a.y.a.C0(e2);
                return f.a.w.a.c.INSTANCE;
            }
        }
        j jVar = new j(runnable);
        try {
            jVar.a(cVarA.f4002b.scheduleAtFixedRate(jVar, j2, j3, timeUnit));
            return jVar;
        } catch (RejectedExecutionException e3) {
            f.a.y.a.C0(e3);
            return f.a.w.a.c.INSTANCE;
        }
    }
}