package I4;

import A2.u;
import B4.A;
import G4.p;
import G4.t;
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.atomic.AtomicReferenceArray;
import java.util.concurrent.locks.LockSupport;
import p0.AbstractC0928a;
import r4.AbstractC0983h;

/* JADX INFO: loaded from: classes.dex */
public final class c implements Executor, Closeable {

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public static final /* synthetic */ AtomicLongFieldUpdater f993r = AtomicLongFieldUpdater.newUpdater(c.class, "parkedWorkersStack$volatile");

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public static final /* synthetic */ AtomicLongFieldUpdater f994s = AtomicLongFieldUpdater.newUpdater(c.class, "controlState$volatile");

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f995t = AtomicIntegerFieldUpdater.newUpdater(c.class, "_isTerminated$volatile");

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public static final t f996u = new t("NOT_IN_STACK", 0);
    private volatile /* synthetic */ int _isTerminated$volatile;
    private volatile /* synthetic */ long controlState$volatile;

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

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

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final long f999m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final String f1000n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public final f f1001o;
    public final f p;
    private volatile /* synthetic */ long parkedWorkersStack$volatile;
    public final p q;

    public c(int i, int i5, long j5, String str) {
        this.f997k = i;
        this.f998l = i5;
        this.f999m = j5;
        this.f1000n = str;
        if (i < 1) {
            throw new IllegalArgumentException(AbstractC0928a.j(i, "Core pool size ", " should be at least 1").toString());
        }
        if (i5 < i) {
            throw new IllegalArgumentException(AbstractC0928a.h(i5, i, "Max pool size ", " should be greater than or equals to core pool size ").toString());
        }
        if (i5 > 2097150) {
            throw new IllegalArgumentException(AbstractC0928a.j(i5, "Max pool size ", " should not exceed maximal supported number of threads 2097150").toString());
        }
        if (j5 <= 0) {
            throw new IllegalArgumentException(("Idle worker keep alive time " + j5 + " must be positive").toString());
        }
        this.f1001o = new f();
        this.p = new f();
        this.q = new p((i + 1) * 2);
        this.controlState$volatile = ((long) i) << 42;
        this._isTerminated$volatile = 0;
    }

    public final int a() {
        synchronized (this.q) {
            try {
                if (f995t.get(this) != 0) {
                    return -1;
                }
                AtomicLongFieldUpdater atomicLongFieldUpdater = f994s;
                long j5 = atomicLongFieldUpdater.get(this);
                int i = (int) (j5 & 2097151);
                int i5 = i - ((int) ((j5 & 4398044413952L) >> 21));
                if (i5 < 0) {
                    i5 = 0;
                }
                if (i5 >= this.f997k) {
                    return 0;
                }
                if (i >= this.f998l) {
                    return 0;
                }
                int i6 = ((int) (atomicLongFieldUpdater.get(this) & 2097151)) + 1;
                if (i6 <= 0 || this.q.b(i6) != null) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                a aVar = new a(this, i6);
                this.q.c(i6, aVar);
                if (i6 != ((int) (2097151 & atomicLongFieldUpdater.incrementAndGet(this)))) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                int i7 = i5 + 1;
                aVar.start();
                return i7;
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:39:0x008a  */
    @Override // java.io.Closeable, java.lang.AutoCloseable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct code enable 'Show inconsistent code' option in preferences
    */
    public final void close() throws java.lang.InterruptedException {
        /*
            r8 = this;
            java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = I4.c.f995t
            r1 = 0
            r2 = 1
            boolean r0 = r0.compareAndSet(r8, r1, r2)
            if (r0 != 0) goto Lb
            return
        Lb:
            java.lang.Thread r0 = java.lang.Thread.currentThread()
            boolean r1 = r0 instanceof I4.a
            r3 = 0
            if (r1 == 0) goto L17
            I4.a r0 = (I4.a) r0
            goto L18
        L17:
            r0 = r3
        L18:
            if (r0 == 0) goto L23
            I4.c r1 = r0.f987r
            boolean r1 = r4.AbstractC0983h.a(r1, r8)
            if (r1 == 0) goto L23
            goto L24
        L23:
            r0 = r3
        L24:
            G4.p r1 = r8.q
            monitor-enter(r1)
            java.util.concurrent.atomic.AtomicLongFieldUpdater r4 = I4.c.f994s     // Catch: java.lang.Throwable -> Lc3
            long r4 = r4.get(r8)     // Catch: java.lang.Throwable -> Lc3
            r6 = 2097151(0x1fffff, double:1.0361303E-317)
            long r4 = r4 & r6
            int r4 = (int) r4
            monitor-exit(r1)
            if (r2 > r4) goto L78
            r1 = r2
        L36:
            G4.p r5 = r8.q
            java.lang.Object r5 = r5.b(r1)
            r4.AbstractC0983h.b(r5)
            I4.a r5 = (I4.a) r5
            if (r5 == r0) goto L73
        L43:
            java.lang.Thread$State r6 = r5.getState()
            java.lang.Thread$State r7 = java.lang.Thread.State.TERMINATED
            if (r6 == r7) goto L54
            java.util.concurrent.locks.LockSupport.unpark(r5)
            r6 = 10000(0x2710, double:4.9407E-320)
            r5.join(r6)
            goto L43
        L54:
            I4.m r5 = r5.f982k
            I4.f r6 = r8.p
            r5.getClass()
            java.util.concurrent.atomic.AtomicReferenceFieldUpdater r7 = I4.m.f1017b
            java.lang.Object r7 = r7.getAndSet(r5, r3)
            I4.i r7 = (I4.i) r7
            if (r7 == 0) goto L68
            r6.a(r7)
        L68:
            I4.i r7 = r5.a()
            if (r7 != 0) goto L6f
            goto L73
        L6f:
            r6.a(r7)
            goto L68
        L73:
            if (r1 == r4) goto L78
            int r1 = r1 + 1
            goto L36
        L78:
            I4.f r1 = r8.p
            r1.b()
            I4.f r1 = r8.f1001o
            r1.b()
        L82:
            if (r0 == 0) goto L8a
            I4.i r1 = r0.a(r2)
            if (r1 != 0) goto Lb2
        L8a:
            I4.f r1 = r8.f1001o
            java.lang.Object r1 = r1.d()
            I4.i r1 = (I4.i) r1
            if (r1 != 0) goto Lb2
            I4.f r1 = r8.p
            java.lang.Object r1 = r1.d()
            I4.i r1 = (I4.i) r1
            if (r1 != 0) goto Lb2
            if (r0 == 0) goto La5
            I4.b r1 = I4.b.f992o
            r0.h(r1)
        La5:
            java.util.concurrent.atomic.AtomicLongFieldUpdater r0 = I4.c.f993r
            r1 = 0
            r0.set(r8, r1)
            java.util.concurrent.atomic.AtomicLongFieldUpdater r0 = I4.c.f994s
            r0.set(r8, r1)
            return
        Lb2:
            r1.run()     // Catch: java.lang.Throwable -> Lb6
            goto L82
        Lb6:
            r1 = move-exception
            java.lang.Thread r3 = java.lang.Thread.currentThread()
            java.lang.Thread$UncaughtExceptionHandler r4 = r3.getUncaughtExceptionHandler()
            r4.uncaughtException(r3, r1)
            goto L82
        Lc3:
            r0 = move-exception
            monitor-exit(r1)
            throw r0
        */
        throw new UnsupportedOperationException("Method not decompiled: I4.c.close():void");
    }

    public final void e(Runnable runnable, boolean z5) {
        i jVar;
        b bVar;
        AtomicReferenceArray atomicReferenceArray;
        k.f1015f.getClass();
        long jNanoTime = System.nanoTime();
        if (runnable instanceof i) {
            jVar = (i) runnable;
            jVar.f1007k = jNanoTime;
            jVar.f1008l = z5;
        } else {
            jVar = new j(runnable, jNanoTime, z5);
        }
        boolean z6 = jVar.f1008l;
        AtomicLongFieldUpdater atomicLongFieldUpdater = f994s;
        long jAddAndGet = z6 ? atomicLongFieldUpdater.addAndGet(this, 2097152L) : 0L;
        Thread threadCurrentThread = Thread.currentThread();
        a aVar = threadCurrentThread instanceof a ? (a) threadCurrentThread : null;
        if (aVar == null || !AbstractC0983h.a(aVar.f987r, this)) {
            aVar = null;
        }
        if (aVar != null && (bVar = aVar.f984m) != b.f992o && (jVar.f1008l || bVar != b.f989l)) {
            aVar.q = true;
            m mVar = aVar.f982k;
            mVar.getClass();
            jVar = (i) m.f1017b.getAndSet(mVar, jVar);
            if (jVar == null) {
                jVar = null;
            } else {
                mVar.getClass();
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = m.f1018c;
                if (atomicIntegerFieldUpdater.get(mVar) - m.f1019d.get(mVar) != 127) {
                    if (jVar.f1008l) {
                        m.f1020e.incrementAndGet(mVar);
                    }
                    int i = atomicIntegerFieldUpdater.get(mVar) & 127;
                    while (true) {
                        atomicReferenceArray = mVar.f1021a;
                        if (atomicReferenceArray.get(i) == null) {
                            break;
                        } else {
                            Thread.yield();
                        }
                    }
                    atomicReferenceArray.lazySet(i, jVar);
                    atomicIntegerFieldUpdater.incrementAndGet(mVar);
                    jVar = null;
                }
            }
        }
        if (jVar != null) {
            if (!(jVar.f1008l ? this.p.a(jVar) : this.f1001o.a(jVar))) {
                throw new RejectedExecutionException(s0.c.e(new StringBuilder(), this.f1000n, " was terminated"));
            }
        }
        if (z6) {
            if (k() || h(jAddAndGet)) {
                return;
            }
            k();
            return;
        }
        if (k() || h(atomicLongFieldUpdater.get(this))) {
            return;
        }
        k();
    }

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

    public final void f(a aVar, int i, int i5) {
        while (true) {
            long j5 = f993r.get(this);
            int i6 = (int) (2097151 & j5);
            long j6 = (2097152 + j5) & (-2097152);
            if (i6 == i) {
                if (i5 == 0) {
                    Object objC = aVar.c();
                    while (true) {
                        if (objC == f996u) {
                            i6 = -1;
                            break;
                        }
                        if (objC == null) {
                            i6 = 0;
                            break;
                        }
                        a aVar2 = (a) objC;
                        int iB = aVar2.b();
                        if (iB != 0) {
                            i6 = iB;
                            break;
                        }
                        objC = aVar2.c();
                    }
                } else {
                    i6 = i5;
                }
            }
            if (i6 >= 0) {
                if (f993r.compareAndSet(this, j5, ((long) i6) | j6)) {
                    return;
                }
            }
        }
    }

    public final boolean h(long j5) {
        int i = ((int) (2097151 & j5)) - ((int) ((j5 & 4398044413952L) >> 21));
        if (i < 0) {
            i = 0;
        }
        int i5 = this.f997k;
        if (i < i5) {
            int iA = a();
            if (iA == 1 && i5 > 1) {
                a();
            }
            if (iA > 0) {
                return true;
            }
        }
        return false;
    }

    public final boolean k() {
        t tVar;
        int iB;
        while (true) {
            AtomicLongFieldUpdater atomicLongFieldUpdater = f993r;
            long j5 = atomicLongFieldUpdater.get(this);
            a aVar = (a) this.q.b((int) (2097151 & j5));
            if (aVar == null) {
                aVar = null;
            } else {
                long j6 = (2097152 + j5) & (-2097152);
                Object objC = aVar.c();
                while (true) {
                    tVar = f996u;
                    if (objC == tVar) {
                        iB = -1;
                        break;
                    }
                    if (objC == null) {
                        iB = 0;
                        break;
                    }
                    a aVar2 = (a) objC;
                    iB = aVar2.b();
                    if (iB != 0) {
                        break;
                    }
                    objC = aVar2.c();
                }
                if (iB >= 0 && atomicLongFieldUpdater.compareAndSet(this, j5, j6 | ((long) iB))) {
                    aVar.g(tVar);
                }
            }
            if (aVar == null) {
                return false;
            }
            if (a.f981s.compareAndSet(aVar, -1, 0)) {
                LockSupport.unpark(aVar);
                return true;
            }
        }
    }

    public final String toString() {
        ArrayList arrayList = new ArrayList();
        p pVar = this.q;
        int iA = pVar.a();
        int i = 0;
        int i5 = 0;
        int i6 = 0;
        int i7 = 0;
        int i8 = 0;
        for (int i9 = 1; i9 < iA; i9++) {
            a aVar = (a) pVar.b(i9);
            if (aVar != null) {
                m mVar = aVar.f982k;
                mVar.getClass();
                int i10 = m.f1017b.get(mVar) != null ? (m.f1018c.get(mVar) - m.f1019d.get(mVar)) + 1 : m.f1018c.get(mVar) - m.f1019d.get(mVar);
                int iOrdinal = aVar.f984m.ordinal();
                if (iOrdinal == 0) {
                    i++;
                    StringBuilder sb = new StringBuilder();
                    sb.append(i10);
                    sb.append('c');
                    arrayList.add(sb.toString());
                } else if (iOrdinal == 1) {
                    i5++;
                    StringBuilder sb2 = new StringBuilder();
                    sb2.append(i10);
                    sb2.append('b');
                    arrayList.add(sb2.toString());
                } else if (iOrdinal == 2) {
                    i6++;
                } else if (iOrdinal == 3) {
                    i7++;
                    if (i10 > 0) {
                        StringBuilder sb3 = new StringBuilder();
                        sb3.append(i10);
                        sb3.append('d');
                        arrayList.add(sb3.toString());
                    }
                } else {
                    if (iOrdinal != 4) {
                        throw new u();
                    }
                    i8++;
                }
            }
        }
        long j5 = f994s.get(this);
        StringBuilder sb4 = new StringBuilder();
        sb4.append(this.f1000n);
        sb4.append('@');
        sb4.append(A.d(this));
        sb4.append("[Pool Size {core = ");
        int i11 = this.f997k;
        sb4.append(i11);
        sb4.append(", max = ");
        sb4.append(this.f998l);
        sb4.append("}, Worker States {CPU = ");
        sb4.append(i);
        sb4.append(", blocking = ");
        sb4.append(i5);
        sb4.append(", parked = ");
        sb4.append(i6);
        sb4.append(", dormant = ");
        sb4.append(i7);
        sb4.append(", terminated = ");
        sb4.append(i8);
        sb4.append("}, running workers queues = ");
        sb4.append(arrayList);
        sb4.append(", global CPU queue size = ");
        sb4.append(this.f1001o.c());
        sb4.append(", global blocking queue size = ");
        sb4.append(this.p.c());
        sb4.append(", Control State {created workers= ");
        sb4.append((int) (2097151 & j5));
        sb4.append(", blocking tasks = ");
        sb4.append((int) ((4398044413952L & j5) >> 21));
        sb4.append(", CPUs acquired = ");
        sb4.append(i11 - ((int) ((j5 & 9223367638808264704L) >> 42)));
        sb4.append("}]");
        return sb4.toString();
    }
}