package c5;

import E3.v;
import I2.C0317a;
import V4.E;
import a5.o;
import java.io.Closeable;
import java.lang.Thread;
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;

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

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

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

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public static final C0317a f13458n = new C0317a("NOT_IN_STACK", 4);
    private volatile /* synthetic */ int _isTerminated$volatile;

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final long f13461c;
    private volatile /* synthetic */ long controlState$volatile;

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

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

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

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

    public c(int i6, int i7, long j4, String str) {
        this.f13459a = i6;
        this.f13460b = i7;
        this.f13461c = j4;
        this.f13462d = str;
        if (i6 < 1) {
            throw new IllegalArgumentException(Z0.o.j(i6, "Core pool size ", " should be at least 1").toString());
        }
        if (i7 < i6) {
            throw new IllegalArgumentException(com.google.android.recaptcha.internal.a.i(i7, i6, "Max pool size ", " should be greater than or equals to core pool size ").toString());
        }
        if (i7 > 2097150) {
            throw new IllegalArgumentException(Z0.o.j(i7, "Max pool size ", " should not exceed maximal supported number of threads 2097150").toString());
        }
        if (j4 <= 0) {
            throw new IllegalArgumentException(("Idle worker keep alive time " + j4 + " must be positive").toString());
        }
        this.f13463e = new f();
        this.f13464f = new f();
        this.f13465j = new o((i6 + 1) * 2);
        this.controlState$volatile = ((long) i6) << 42;
        this._isTerminated$volatile = 0;
    }

    public static /* synthetic */ void c(c cVar, Runnable runnable, int i6) {
        cVar.b(runnable, false, (i6 & 4) == 0);
    }

    public final int a() {
        synchronized (this.f13465j) {
            try {
                if (f13457m.get(this) != 0) {
                    return -1;
                }
                AtomicLongFieldUpdater atomicLongFieldUpdater = l;
                long j4 = atomicLongFieldUpdater.get(this);
                int i6 = (int) (j4 & 2097151);
                int i7 = i6 - ((int) ((j4 & 4398044413952L) >> 21));
                if (i7 < 0) {
                    i7 = 0;
                }
                if (i7 >= this.f13459a) {
                    return 0;
                }
                if (i6 >= this.f13460b) {
                    return 0;
                }
                int i8 = ((int) (atomicLongFieldUpdater.get(this) & 2097151)) + 1;
                if (i8 <= 0 || this.f13465j.b(i8) != null) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                a aVar = new a(this, i8);
                this.f13465j.c(i8, aVar);
                if (i8 != ((int) (2097151 & atomicLongFieldUpdater.incrementAndGet(this)))) {
                    throw new IllegalArgumentException("Failed requirement.");
                }
                int i9 = i7 + 1;
                aVar.start();
                return i9;
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final void b(Runnable runnable, boolean z6, boolean z7) {
        i jVar;
        b bVar;
        k.f13479f.getClass();
        long jNanoTime = System.nanoTime();
        if (runnable instanceof i) {
            jVar = (i) runnable;
            jVar.f13471a = jNanoTime;
            jVar.f13472b = z6;
        } else {
            jVar = new j(runnable, jNanoTime, z6);
        }
        boolean z8 = jVar.f13472b;
        AtomicLongFieldUpdater atomicLongFieldUpdater = l;
        long jAddAndGet = z8 ? atomicLongFieldUpdater.addAndGet(this, 2097152L) : 0L;
        Thread threadCurrentThread = Thread.currentThread();
        a aVar = threadCurrentThread instanceof a ? (a) threadCurrentThread : null;
        if (aVar == null || !kotlin.jvm.internal.o.c(aVar.f13449k, this)) {
            aVar = null;
        }
        if (aVar != null && (bVar = aVar.f13444c) != b.f13454e && (jVar.f13472b || bVar != b.f13451b)) {
            aVar.f13448j = true;
            m mVar = aVar.f13442a;
            if (z7) {
                jVar = mVar.a(jVar);
            } else {
                mVar.getClass();
                i iVar = (i) m.f13481b.getAndSet(mVar, jVar);
                jVar = iVar == null ? null : mVar.a(iVar);
            }
        }
        if (jVar != null) {
            if (!(jVar.f13472b ? this.f13464f.a(jVar) : this.f13463e.a(jVar))) {
                throw new RejectedExecutionException(com.google.android.recaptcha.internal.a.n(new StringBuilder(), this.f13462d, " was terminated"));
            }
        }
        boolean z9 = z7 && aVar != null;
        if (z8) {
            if (z9 || g() || f(jAddAndGet)) {
                return;
            }
            g();
            return;
        }
        if (z9 || g() || f(atomicLongFieldUpdater.get(this))) {
            return;
        }
        g();
    }

    /* 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.
    */
    public final void close() throws InterruptedException {
        int i6;
        i iVarA;
        if (f13457m.compareAndSet(this, 0, 1)) {
            Thread threadCurrentThread = Thread.currentThread();
            a aVar = threadCurrentThread instanceof a ? (a) threadCurrentThread : null;
            if (aVar == null || !kotlin.jvm.internal.o.c(aVar.f13449k, this)) {
                aVar = null;
            }
            synchronized (this.f13465j) {
                i6 = (int) (l.get(this) & 2097151);
            }
            if (1 <= i6) {
                int i7 = 1;
                while (true) {
                    Object objB = this.f13465j.b(i7);
                    kotlin.jvm.internal.o.e(objB);
                    a aVar2 = (a) objB;
                    if (aVar2 != aVar) {
                        while (aVar2.getState() != Thread.State.TERMINATED) {
                            LockSupport.unpark(aVar2);
                            aVar2.join(10000L);
                        }
                        m mVar = aVar2.f13442a;
                        f fVar = this.f13464f;
                        mVar.getClass();
                        i iVar = (i) m.f13481b.getAndSet(mVar, null);
                        if (iVar != null) {
                            fVar.a(iVar);
                        }
                        while (true) {
                            i iVarB = mVar.b();
                            if (iVarB == null) {
                                break;
                            } else {
                                fVar.a(iVarB);
                            }
                        }
                    }
                    if (i7 == i6) {
                        break;
                    } else {
                        i7++;
                    }
                }
            }
            this.f13464f.b();
            this.f13463e.b();
            while (true) {
                if (aVar == null) {
                    iVarA = (i) this.f13463e.d();
                    if (iVarA == null && (iVarA = (i) this.f13464f.d()) == null) {
                        break;
                    }
                } else {
                    iVarA = aVar.a(true);
                    if (iVarA == null) {
                    }
                }
                try {
                    iVarA.run();
                } catch (Throwable th) {
                    Thread threadCurrentThread2 = Thread.currentThread();
                    threadCurrentThread2.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread2, th);
                }
            }
            if (aVar != null) {
                aVar.h(b.f13454e);
            }
            f13456k.set(this, 0L);
            l.set(this, 0L);
        }
    }

    public final void d(a aVar, int i6, int i7) {
        while (true) {
            long j4 = f13456k.get(this);
            int i8 = (int) (2097151 & j4);
            long j6 = (2097152 + j4) & (-2097152);
            if (i8 == i6) {
                if (i7 == 0) {
                    Object objC = aVar.c();
                    while (true) {
                        if (objC == f13458n) {
                            i8 = -1;
                            break;
                        }
                        if (objC == null) {
                            i8 = 0;
                            break;
                        }
                        a aVar2 = (a) objC;
                        int iB = aVar2.b();
                        if (iB != 0) {
                            i8 = iB;
                            break;
                        }
                        objC = aVar2.c();
                    }
                } else {
                    i8 = i7;
                }
            }
            if (i8 >= 0) {
                if (f13456k.compareAndSet(this, j4, ((long) i8) | j6)) {
                    return;
                }
            }
        }
    }

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

    public final boolean f(long j4) {
        int i6 = ((int) (2097151 & j4)) - ((int) ((j4 & 4398044413952L) >> 21));
        if (i6 < 0) {
            i6 = 0;
        }
        int i7 = this.f13459a;
        if (i6 < i7) {
            int iA = a();
            if (iA == 1 && i7 > 1) {
                a();
            }
            if (iA > 0) {
                return true;
            }
        }
        return false;
    }

    public final boolean g() {
        C0317a c0317a;
        int iB;
        while (true) {
            AtomicLongFieldUpdater atomicLongFieldUpdater = f13456k;
            long j4 = atomicLongFieldUpdater.get(this);
            a aVar = (a) this.f13465j.b((int) (2097151 & j4));
            if (aVar == null) {
                aVar = null;
            } else {
                long j6 = (2097152 + j4) & (-2097152);
                Object objC = aVar.c();
                while (true) {
                    c0317a = f13458n;
                    if (objC == c0317a) {
                        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, j4, j6 | ((long) iB))) {
                    aVar.g(c0317a);
                }
            }
            if (aVar == null) {
                return false;
            }
            if (a.l.compareAndSet(aVar, -1, 0)) {
                LockSupport.unpark(aVar);
                return true;
            }
        }
    }

    public final String toString() {
        ArrayList arrayList = new ArrayList();
        o oVar = this.f13465j;
        int iA = oVar.a();
        int i6 = 0;
        int i7 = 0;
        int i8 = 0;
        int i9 = 0;
        int i10 = 0;
        for (int i11 = 1; i11 < iA; i11++) {
            a aVar = (a) oVar.b(i11);
            if (aVar != null) {
                m mVar = aVar.f13442a;
                mVar.getClass();
                int i12 = m.f13481b.get(mVar) != null ? (m.f13482c.get(mVar) - m.f13483d.get(mVar)) + 1 : m.f13482c.get(mVar) - m.f13483d.get(mVar);
                int iOrdinal = aVar.f13444c.ordinal();
                if (iOrdinal == 0) {
                    i6++;
                    StringBuilder sb = new StringBuilder();
                    sb.append(i12);
                    sb.append('c');
                    arrayList.add(sb.toString());
                } else if (iOrdinal == 1) {
                    i7++;
                    StringBuilder sb2 = new StringBuilder();
                    sb2.append(i12);
                    sb2.append('b');
                    arrayList.add(sb2.toString());
                } else if (iOrdinal == 2) {
                    i8++;
                } else if (iOrdinal == 3) {
                    i9++;
                    if (i12 > 0) {
                        StringBuilder sb3 = new StringBuilder();
                        sb3.append(i12);
                        sb3.append('d');
                        arrayList.add(sb3.toString());
                    }
                } else {
                    if (iOrdinal != 4) {
                        throw new v();
                    }
                    i10++;
                }
            }
        }
        long j4 = l.get(this);
        StringBuilder sb4 = new StringBuilder();
        sb4.append(this.f13462d);
        sb4.append('@');
        sb4.append(E.p(this));
        sb4.append("[Pool Size {core = ");
        int i13 = this.f13459a;
        sb4.append(i13);
        sb4.append(", max = ");
        sb4.append(this.f13460b);
        sb4.append("}, Worker States {CPU = ");
        sb4.append(i6);
        sb4.append(", blocking = ");
        sb4.append(i7);
        sb4.append(", parked = ");
        sb4.append(i8);
        sb4.append(", dormant = ");
        sb4.append(i9);
        sb4.append(", terminated = ");
        sb4.append(i10);
        sb4.append("}, running workers queues = ");
        sb4.append(arrayList);
        sb4.append(", global CPU queue size = ");
        sb4.append(this.f13463e.c());
        sb4.append(", global blocking queue size = ");
        sb4.append(this.f13464f.c());
        sb4.append(", Control State {created workers= ");
        sb4.append((int) (2097151 & j4));
        sb4.append(", blocking tasks = ");
        sb4.append((int) ((4398044413952L & j4) >> 21));
        sb4.append(", CPUs acquired = ");
        sb4.append(i13 - ((int) ((j4 & 9223367638808264704L) >> 42)));
        sb4.append("}]");
        return sb4.toString();
    }
}