package defpackage;

import java.io.Closeable;
import java.util.ArrayList;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
import java.util.concurrent.locks.LockSupport;

/* renamed from: ˏᵞ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class ExecutorC1873 implements Executor, Closeable {
    private volatile /* synthetic */ int _isTerminated$volatile;
    private volatile /* synthetic */ long controlState$volatile;
    private volatile /* synthetic */ long parkedWorkersStack$volatile;

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public final C0856 f7582;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final C2174 f7583;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final int f7584;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final C2174 f7585;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final int f7586;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final String f7587;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final long f7588;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicLongFieldUpdater f7580 = AtomicLongFieldUpdater.newUpdater(ExecutorC1873.class, "parkedWorkersStack$volatile");

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicLongFieldUpdater f7579 = AtomicLongFieldUpdater.newUpdater(ExecutorC1873.class, "controlState$volatile");

    /* renamed from: ˎˑː, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f7578 = AtomicIntegerFieldUpdater.newUpdater(ExecutorC1873.class, "_isTerminated$volatile");

    /* renamed from: ᵮᵠـˌ, reason: contains not printable characters */
    public static final C0434 f7581 = new C0434(9, "NOT_IN_STACK");

    public ExecutorC1873(int i, int i2, long j, String str) {
        this.f7586 = i;
        this.f7584 = i2;
        this.f7588 = j;
        this.f7587 = str;
        if (i < 1) {
            ᵹˉᵞ.ᵸˑ(AbstractC3915.m8596(i, "Core pool size ", " should be at least 1"));
            throw null;
        }
        if (i2 < i) {
            ᵹˉᵞ.ᵸˑ(AbstractC1327.m4091(i2, i, "Max pool size ", " should be greater than or equals to core pool size "));
            throw null;
        }
        if (i2 > 2097150) {
            ᵹˉᵞ.ᵸˑ(AbstractC3915.m8596(i2, "Max pool size ", " should not exceed maximal supported number of threads 2097150"));
            throw null;
        }
        if (j <= 0) {
            ᵹˉᵞ.ᵸˑ(AbstractC4486.m9547(j, "Idle worker keep alive time ", " must be positive"));
            throw null;
        }
        this.f7585 = new C2174();
        this.f7583 = new C2174();
        this.f7582 = new C0856((i + 1) * 2);
        this.controlState$volatile = i << 42;
    }

    /* renamed from: ˌʾˀ, reason: contains not printable characters */
    public static /* synthetic */ void m5278(ExecutorC1873 executorC1873, Runnable runnable, int i) {
        executorC1873.m5279(runnable, false, (i & 4) == 0);
    }

    /* JADX WARN: Removed duplicated region for block: B:38:0x0089  */
    @Override // java.io.Closeable, java.lang.AutoCloseable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void close() throws java.lang.InterruptedException {
        /*
            r10 = this;
            java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = defpackage.ExecutorC1873.f7578
            r1 = 0
            r2 = 1
            boolean r0 = r0.compareAndSet(r10, r1, r2)
            if (r0 != 0) goto Lb
            return
        Lb:
            java.lang.Thread r0 = java.lang.Thread.currentThread()
            boolean r1 = r0 instanceof defpackage.C4117
            r3 = 0
            if (r1 == 0) goto L17
            ᵭːʚ r0 = (defpackage.C4117) r0
            goto L18
        L17:
            r0 = r3
        L18:
            if (r0 == 0) goto L1e
            ˏᵞ r1 = r0.f15373
            if (r1 == r10) goto L1f
        L1e:
            r0 = r3
        L1f:
            ˆᵠٴᵮ r1 = r10.f7582
            monitor-enter(r1)
            java.util.concurrent.atomic.AtomicLongFieldUpdater r4 = defpackage.ExecutorC1873.f7579     // Catch: java.lang.Throwable -> Lc1
            long r4 = r4.get(r10)     // Catch: java.lang.Throwable -> Lc1
            r6 = 2097151(0x1fffff, double:1.0361303E-317)
            long r4 = r4 & r6
            int r4 = (int) r4
            monitor-exit(r1)
            if (r2 > r4) goto L77
            r1 = r2
        L31:
            ˆᵠٴᵮ r5 = r10.f7582
            java.lang.Object r5 = r5.m2980(r1)
            ᵭːʚ r5 = (defpackage.C4117) r5
            if (r5 == r0) goto L72
        L3b:
            java.lang.Thread$State r6 = r5.getState()
            java.lang.Thread$State r7 = java.lang.Thread.State.TERMINATED
            if (r6 == r7) goto L4c
            java.util.concurrent.locks.LockSupport.unpark(r5)
            r6 = 10000(0x2710, double:4.9407E-320)
            r5.join(r6)
            goto L3b
        L4c:
            ᵢᵵᵲˋ r5 = r5.f15377
            ᴵʽ r6 = r10.f7583
            r5.getClass()
            java.util.concurrent.atomic.AtomicReferenceFieldUpdater r7 = defpackage.C3302.f12370
            r7.getClass()
            sun.misc.Unsafe r7 = defpackage.AbstractC3747.f13986
            long r8 = defpackage.C3302.f12368
            java.lang.Object r7 = defpackage.AbstractC3747.m8370(r7, r5, r8, r3)
            ᵗᵿᵛ r7 = (defpackage.AbstractRunnableC2488) r7
            if (r7 == 0) goto L67
            r6.m4267(r7)
        L67:
            ᵗᵿᵛ r7 = r5.m7688()
            if (r7 != 0) goto L6e
            goto L72
        L6e:
            r6.m4267(r7)
            goto L67
        L72:
            if (r1 == r4) goto L77
            int r1 = r1 + 1
            goto L31
        L77:
            ᴵʽ r1 = r10.f7583
            r1.m4268()
            ᴵʽ r1 = r10.f7585
            r1.m4268()
        L81:
            if (r0 == 0) goto L89
            ᵗᵿᵛ r1 = r0.m9017(r2)
            if (r1 != 0) goto Lb0
        L89:
            ᴵʽ r1 = r10.f7585
            java.lang.Object r1 = r1.m4269()
            ᵗᵿᵛ r1 = (defpackage.AbstractRunnableC2488) r1
            if (r1 != 0) goto Lb0
            ᴵʽ r1 = r10.f7583
            java.lang.Object r1 = r1.m4269()
            ᵗᵿᵛ r1 = (defpackage.AbstractRunnableC2488) r1
            if (r1 != 0) goto Lb0
            if (r0 == 0) goto La3
            r1 = 5
            r0.m9019(r1)
        La3:
            java.util.concurrent.atomic.AtomicLongFieldUpdater r0 = defpackage.ExecutorC1873.f7580
            r1 = 0
            r0.set(r10, r1)
            java.util.concurrent.atomic.AtomicLongFieldUpdater r0 = defpackage.ExecutorC1873.f7579
            r0.set(r10, r1)
            return
        Lb0:
            r1.run()     // Catch: java.lang.Throwable -> Lb4
            goto L81
        Lb4:
            r1 = move-exception
            java.lang.Thread r3 = java.lang.Thread.currentThread()
            java.lang.Thread$UncaughtExceptionHandler r4 = r3.getUncaughtExceptionHandler()
            r4.uncaughtException(r3, r1)
            goto L81
        Lc1:
            r10 = move-exception
            monitor-exit(r1)
            throw r10
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.ExecutorC1873.close():void");
    }

    @Override // java.util.concurrent.Executor
    public final void execute(Runnable runnable) {
        m5278(this, runnable, 6);
    }

    public final String toString() {
        ArrayList arrayList = new ArrayList();
        C0856 c0856 = this.f7582;
        int iM2979 = c0856.m2979();
        int i = 0;
        int i2 = 0;
        int i3 = 0;
        int i4 = 0;
        int i5 = 0;
        for (int i6 = 1; i6 < iM2979; i6++) {
            C4117 c4117 = (C4117) c0856.m2980(i6);
            if (c4117 != null) {
                int iM7690 = c4117.f15377.m7690();
                int iM4088 = AbstractC1327.m4088(c4117.f15379);
                if (iM4088 == 0) {
                    i++;
                    StringBuilder sb = new StringBuilder();
                    sb.append(iM7690);
                    sb.append('c');
                    arrayList.add(sb.toString());
                } else if (iM4088 == 1) {
                    i2++;
                    StringBuilder sb2 = new StringBuilder();
                    sb2.append(iM7690);
                    sb2.append('b');
                    arrayList.add(sb2.toString());
                } else if (iM4088 == 2) {
                    i3++;
                } else if (iM4088 == 3) {
                    i4++;
                    if (iM7690 > 0) {
                        StringBuilder sb3 = new StringBuilder();
                        sb3.append(iM7690);
                        sb3.append('d');
                        arrayList.add(sb3.toString());
                    }
                } else {
                    if (iM4088 != 4) {
                        C0910.m3049();
                        return null;
                    }
                    i5++;
                }
            }
        }
        long j = f7579.get(this);
        StringBuilder sb4 = new StringBuilder();
        sb4.append(this.f7587);
        sb4.append('@');
        sb4.append(ˁـᵛ.ᵳٴᵶ(this));
        sb4.append("[Pool Size {core = ");
        int i7 = this.f7586;
        sb4.append(i7);
        sb4.append(", max = ");
        sb4.append(this.f7584);
        sb4.append("}, Worker States {CPU = ");
        sb4.append(i);
        sb4.append(", blocking = ");
        sb4.append(i2);
        sb4.append(", parked = ");
        sb4.append(i3);
        sb4.append(", dormant = ");
        sb4.append(i4);
        sb4.append(", terminated = ");
        sb4.append(i5);
        sb4.append("}, running workers queues = ");
        sb4.append(arrayList);
        sb4.append(", global CPU queue size = ");
        sb4.append(this.f7585.m4266());
        sb4.append(", global blocking queue size = ");
        sb4.append(this.f7583.m4266());
        sb4.append(", Control State {created workers= ");
        sb4.append((int) (2097151 & j));
        sb4.append(", blocking tasks = ");
        sb4.append((int) ((4398044413952L & j) >> 21));
        sb4.append(", CPUs acquired = ");
        sb4.append(i7 - ((int) ((j & 9223367638808264704L) >> 42)));
        sb4.append("}]");
        return sb4.toString();
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final void m5279(Runnable runnable, boolean z, boolean z2) {
        AbstractRunnableC2488 c1318;
        int i;
        AbstractC2478.f9687.getClass();
        long jNanoTime = System.nanoTime();
        if (runnable instanceof AbstractRunnableC2488) {
            c1318 = (AbstractRunnableC2488) runnable;
            c1318.f9714 = jNanoTime;
            c1318.f9713 = z;
        } else {
            c1318 = new C1318(runnable, jNanoTime, z);
        }
        boolean z3 = c1318.f9713;
        AtomicLongFieldUpdater atomicLongFieldUpdater = f7579;
        long jAddAndGet = z3 ? atomicLongFieldUpdater.addAndGet(this, 2097152L) : 0L;
        Thread threadCurrentThread = Thread.currentThread();
        C4117 c4117 = threadCurrentThread instanceof C4117 ? (C4117) threadCurrentThread : null;
        if (c4117 == null || c4117.f15373 != this) {
            c4117 = null;
        }
        if (c4117 != null && (i = c4117.f15379) != 5 && (c1318.f9713 || i != 2)) {
            c4117.f15372 = true;
            C3302 c3302 = c4117.f15377;
            if (z2) {
                c1318 = c3302.m7689(c1318);
            } else {
                c3302.getClass();
                C3302.f12370.getClass();
                AbstractRunnableC2488 abstractRunnableC2488 = (AbstractRunnableC2488) AbstractC3747.m8370(AbstractC3747.f13986, c3302, C3302.f12368, c1318);
                c1318 = abstractRunnableC2488 == null ? null : c3302.m7689(abstractRunnableC2488);
            }
        }
        if (c1318 != null) {
            if (!(c1318.f9713 ? this.f7583.m4267(c1318) : this.f7585.m4267(c1318))) {
                throw new RejectedExecutionException(AbstractC1327.m4107(new StringBuilder(), this.f7587, " was terminated"));
            }
        }
        if (z3) {
            if (m5281() || m5282(jAddAndGet)) {
                return;
            }
            m5281();
            return;
        }
        if (m5281() || m5282(atomicLongFieldUpdater.get(this))) {
            return;
        }
        m5281();
    }

    /* renamed from: ᵞʡ, reason: contains not printable characters */
    public final void m5280(C4117 c4117, int i, int i2) {
        while (true) {
            long j = f7580.get(this);
            int i3 = (int) (2097151 & j);
            long j2 = (2097152 + j) & (-2097152);
            if (i3 == i) {
                if (i2 == 0) {
                    Object objM9015 = c4117.m9015();
                    while (true) {
                        if (objM9015 == f7581) {
                            i3 = -1;
                            break;
                        }
                        if (objM9015 == null) {
                            i3 = 0;
                            break;
                        }
                        C4117 c41172 = (C4117) objM9015;
                        int iM9018 = c41172.m9018();
                        if (iM9018 != 0) {
                            i3 = iM9018;
                            break;
                        }
                        objM9015 = c41172.m9015();
                    }
                } else {
                    i3 = i2;
                }
            }
            if (i3 >= 0) {
                ExecutorC1873 executorC1873 = this;
                if (f7580.compareAndSet(executorC1873, j, i3 | j2)) {
                    return;
                } else {
                    this = executorC1873;
                }
            }
        }
    }

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final boolean m5281() {
        ExecutorC1873 executorC1873;
        C0434 c0434;
        int iM9018;
        while (true) {
            long j = f7580.get(this);
            C4117 c4117 = (C4117) this.f7582.m2980((int) (2097151 & j));
            if (c4117 == null) {
                c4117 = null;
                executorC1873 = this;
            } else {
                long j2 = (2097152 + j) & (-2097152);
                Object objM9015 = c4117.m9015();
                while (true) {
                    c0434 = f7581;
                    if (objM9015 == c0434) {
                        iM9018 = -1;
                        break;
                    }
                    if (objM9015 == null) {
                        iM9018 = 0;
                        break;
                    }
                    C4117 c41172 = (C4117) objM9015;
                    iM9018 = c41172.m9018();
                    if (iM9018 != 0) {
                        break;
                    }
                    objM9015 = c41172.m9015();
                    j = j;
                }
                if (iM9018 >= 0) {
                    ExecutorC1873 executorC18732 = this;
                    boolean zCompareAndSet = f7580.compareAndSet(executorC18732, j, iM9018 | j2);
                    executorC1873 = executorC18732;
                    if (zCompareAndSet) {
                        c4117.m9013(c0434);
                    }
                    this = executorC1873;
                } else {
                    continue;
                }
            }
            if (c4117 == null) {
                return false;
            }
            if (C4117.f15371.compareAndSet(c4117, -1, 0)) {
                LockSupport.unpark(c4117);
                return true;
            }
            this = executorC1873;
        }
    }

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final boolean m5282(long j) {
        int i = ((int) (2097151 & j)) - ((int) ((j & 4398044413952L) >> 21));
        if (i < 0) {
            i = 0;
        }
        int i2 = this.f7586;
        if (i < i2) {
            int iM5283 = m5283();
            if (iM5283 == 1 && i2 > 1) {
                m5283();
            }
            if (iM5283 > 0) {
                return true;
            }
        }
        return false;
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final int m5283() {
        synchronized (this.f7582) {
            try {
                if (f7578.get(this) == 1) {
                    return -1;
                }
                AtomicLongFieldUpdater atomicLongFieldUpdater = f7579;
                long j = atomicLongFieldUpdater.get(this);
                int i = (int) (j & 2097151);
                int i2 = i - ((int) ((j & 4398044413952L) >> 21));
                if (i2 < 0) {
                    i2 = 0;
                }
                if (i2 >= this.f7586) {
                    return 0;
                }
                if (i >= this.f7584) {
                    return 0;
                }
                int i3 = ((int) (atomicLongFieldUpdater.get(this) & 2097151)) + 1;
                if (i3 <= 0 || this.f7582.m2980(i3) != null) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                C4117 c4117 = new C4117(this, i3);
                this.f7582.m2978(i3, c4117);
                if (i3 != ((int) (2097151 & atomicLongFieldUpdater.incrementAndGet(this)))) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                int i4 = i2 + 1;
                c4117.start();
                return i4;
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}