package be;

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;
import kotlinx.coroutines.internal.q;
import kotlinx.coroutines.scheduling.CoroutineScheduler$WorkerState;
import kotlinx.coroutines.y;

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

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

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

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

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public static final la.e f4822k = new la.e("NOT_IN_STACK");
    private volatile /* synthetic */ int _isTerminated$volatile;

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

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

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

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

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

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

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

    public b(int i10, long j10, int i11, String str) {
        this.f4823a = i10;
        this.f4824b = i11;
        this.f4825c = j10;
        this.f4826d = str;
        if (i10 < 1) {
            throw new IllegalArgumentException(defpackage.e.e("Core pool size ", i10, " should be at least 1").toString());
        }
        if (i11 < i10) {
            throw new IllegalArgumentException(defpackage.e.f("Max pool size ", i11, " should be greater than or equals to core pool size ", i10).toString());
        }
        if (i11 > 2097150) {
            throw new IllegalArgumentException(defpackage.e.e("Max pool size ", i11, " should not exceed maximal supported number of threads 2097150").toString());
        }
        if (j10 <= 0) {
            throw new IllegalArgumentException(("Idle worker keep alive time " + j10 + " must be positive").toString());
        }
        this.f4827e = new e();
        this.f4828f = new e();
        this.f4829g = new q((i10 + 1) * 2);
        this.controlState$volatile = ((long) i10) << 42;
        this._isTerminated$volatile = 0;
    }

    /* JADX WARN: Removed duplicated region for block: B:39:0x008b  */
    @Override // java.io.Closeable, java.lang.AutoCloseable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void close() throws InterruptedException {
        int i10;
        h hVarA;
        if (f4821j.compareAndSet(this, 0, 1)) {
            Thread threadCurrentThread = Thread.currentThread();
            a aVar = threadCurrentThread instanceof a ? (a) threadCurrentThread : null;
            if (aVar == null || !nb.g.c(aVar.f4818h, this)) {
                aVar = null;
            }
            synchronized (this.f4829g) {
                i10 = (int) (f4820i.get(this) & 2097151);
            }
            if (1 <= i10) {
                int i11 = 1;
                while (true) {
                    Object objB = this.f4829g.b(i11);
                    nb.g.f(objB);
                    a aVar2 = (a) objB;
                    if (aVar2 != aVar) {
                        while (aVar2.getState() != Thread.State.TERMINATED) {
                            LockSupport.unpark(aVar2);
                            aVar2.join(10000L);
                        }
                        l lVar = aVar2.f4811a;
                        e eVar = this.f4828f;
                        lVar.getClass();
                        h hVar = (h) l.f4847b.getAndSet(lVar, null);
                        if (hVar != null) {
                            eVar.a(hVar);
                        }
                        while (true) {
                            h hVarB = lVar.b();
                            if (hVarB == null) {
                                break;
                            } else {
                                eVar.a(hVarB);
                            }
                        }
                    }
                    if (i11 == i10) {
                        break;
                    } else {
                        i11++;
                    }
                }
            }
            this.f4828f.b();
            this.f4827e.b();
            while (true) {
                if (aVar == null) {
                    hVarA = (h) this.f4827e.d();
                    if (hVarA == null && (hVarA = (h) this.f4828f.d()) == null) {
                        break;
                    }
                } else {
                    hVarA = aVar.a(true);
                    if (hVarA == null) {
                    }
                }
                try {
                    hVarA.run();
                } catch (Throwable th) {
                    Thread threadCurrentThread2 = Thread.currentThread();
                    threadCurrentThread2.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread2, th);
                }
            }
            if (aVar != null) {
                aVar.h(CoroutineScheduler$WorkerState.f29538e);
            }
            f4819h.set(this, 0L);
            f4820i.set(this, 0L);
        }
    }

    public final int e() {
        synchronized (this.f4829g) {
            try {
                if (f4821j.get(this) != 0) {
                    return -1;
                }
                AtomicLongFieldUpdater atomicLongFieldUpdater = f4820i;
                long j10 = atomicLongFieldUpdater.get(this);
                int i10 = (int) (j10 & 2097151);
                int i11 = i10 - ((int) ((j10 & 4398044413952L) >> 21));
                if (i11 < 0) {
                    i11 = 0;
                }
                if (i11 >= this.f4823a) {
                    return 0;
                }
                if (i10 >= this.f4824b) {
                    return 0;
                }
                int i12 = ((int) (atomicLongFieldUpdater.get(this) & 2097151)) + 1;
                if (i12 <= 0 || this.f4829g.b(i12) != null) {
                    throw new IllegalArgumentException("Failed requirement.".toString());
                }
                a aVar = new a(this, i12);
                this.f4829g.c(i12, aVar);
                if (i12 != ((int) (2097151 & atomicLongFieldUpdater.incrementAndGet(this)))) {
                    throw new IllegalArgumentException("Failed requirement.".toString());
                }
                int i13 = i11 + 1;
                aVar.start();
                return i13;
            } catch (Throwable th) {
                throw th;
            }
        }
    }

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

    public final void g(Runnable runnable, androidx.datastore.preferences.protobuf.h hVar, boolean z10) {
        h iVar;
        CoroutineScheduler$WorkerState coroutineScheduler$WorkerState;
        j.f4843f.getClass();
        long jNanoTime = System.nanoTime();
        if (runnable instanceof h) {
            iVar = (h) runnable;
            iVar.f4835a = jNanoTime;
            iVar.f4836b = hVar;
        } else {
            iVar = new i(runnable, jNanoTime, hVar);
        }
        boolean z11 = false;
        boolean z12 = iVar.f4836b.f2073a == 1;
        AtomicLongFieldUpdater atomicLongFieldUpdater = f4820i;
        long jAddAndGet = z12 ? atomicLongFieldUpdater.addAndGet(this, 2097152L) : 0L;
        Thread threadCurrentThread = Thread.currentThread();
        a aVar = threadCurrentThread instanceof a ? (a) threadCurrentThread : null;
        if (aVar == null || !nb.g.c(aVar.f4818h, this)) {
            aVar = null;
        }
        if (aVar != null && (coroutineScheduler$WorkerState = aVar.f4813c) != CoroutineScheduler$WorkerState.f29538e && (iVar.f4836b.f2073a != 0 || coroutineScheduler$WorkerState != CoroutineScheduler$WorkerState.f29535b)) {
            aVar.f4817g = true;
            l lVar = aVar.f4811a;
            if (z10) {
                iVar = lVar.a(iVar);
            } else {
                lVar.getClass();
                h hVar2 = (h) l.f4847b.getAndSet(lVar, iVar);
                iVar = hVar2 == null ? null : lVar.a(hVar2);
            }
        }
        if (iVar != null) {
            if (!(iVar.f4836b.f2073a == 1 ? this.f4828f.a(iVar) : this.f4827e.a(iVar))) {
                throw new RejectedExecutionException(defpackage.e.o(new StringBuilder(), this.f4826d, " was terminated"));
            }
        }
        if (z10 && aVar != null) {
            z11 = true;
        }
        if (z12) {
            if (z11 || p() || m(jAddAndGet)) {
                return;
            }
            p();
            return;
        }
        if (z11 || p() || m(atomicLongFieldUpdater.get(this))) {
            return;
        }
        p();
    }

    public final void k(a aVar, int i10, int i11) {
        while (true) {
            long j10 = f4819h.get(this);
            int i12 = (int) (2097151 & j10);
            long j11 = (2097152 + j10) & (-2097152);
            if (i12 == i10) {
                if (i11 == 0) {
                    Object objC = aVar.c();
                    while (true) {
                        if (objC == f4822k) {
                            i12 = -1;
                            break;
                        }
                        if (objC == null) {
                            i12 = 0;
                            break;
                        }
                        a aVar2 = (a) objC;
                        int iB = aVar2.b();
                        if (iB != 0) {
                            i12 = iB;
                            break;
                        }
                        objC = aVar2.c();
                    }
                } else {
                    i12 = i11;
                }
            }
            if (i12 >= 0 && f4819h.compareAndSet(this, j10, ((long) i12) | j11)) {
                return;
            }
        }
    }

    public final boolean m(long j10) {
        int i10 = ((int) (2097151 & j10)) - ((int) ((j10 & 4398044413952L) >> 21));
        if (i10 < 0) {
            i10 = 0;
        }
        int i11 = this.f4823a;
        if (i10 < i11) {
            int iE = e();
            if (iE == 1 && i11 > 1) {
                e();
            }
            if (iE > 0) {
                return true;
            }
        }
        return false;
    }

    public final boolean p() {
        la.e eVar;
        int iB;
        while (true) {
            AtomicLongFieldUpdater atomicLongFieldUpdater = f4819h;
            long j10 = atomicLongFieldUpdater.get(this);
            a aVar = (a) this.f4829g.b((int) (2097151 & j10));
            if (aVar == null) {
                aVar = null;
            } else {
                long j11 = (2097152 + j10) & (-2097152);
                Object objC = aVar.c();
                while (true) {
                    eVar = f4822k;
                    if (objC == eVar) {
                        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, j10, j11 | ((long) iB))) {
                    aVar.g(eVar);
                }
            }
            if (aVar == null) {
                return false;
            }
            if (a.f4810i.compareAndSet(aVar, -1, 0)) {
                LockSupport.unpark(aVar);
                return true;
            }
        }
    }

    public final String toString() {
        ArrayList arrayList = new ArrayList();
        q qVar = this.f4829g;
        int iA = qVar.a();
        int i10 = 0;
        int i11 = 0;
        int i12 = 0;
        int i13 = 0;
        int i14 = 0;
        for (int i15 = 1; i15 < iA; i15++) {
            a aVar = (a) qVar.b(i15);
            if (aVar != null) {
                l lVar = aVar.f4811a;
                lVar.getClass();
                int i16 = l.f4847b.get(lVar) != null ? (l.f4848c.get(lVar) - l.f4849d.get(lVar)) + 1 : l.f4848c.get(lVar) - l.f4849d.get(lVar);
                int iOrdinal = aVar.f4813c.ordinal();
                if (iOrdinal == 0) {
                    i10++;
                    StringBuilder sb = new StringBuilder();
                    sb.append(i16);
                    sb.append('c');
                    arrayList.add(sb.toString());
                } else if (iOrdinal == 1) {
                    i11++;
                    StringBuilder sb2 = new StringBuilder();
                    sb2.append(i16);
                    sb2.append('b');
                    arrayList.add(sb2.toString());
                } else if (iOrdinal == 2) {
                    i12++;
                } else if (iOrdinal == 3) {
                    i13++;
                    if (i16 > 0) {
                        StringBuilder sb3 = new StringBuilder();
                        sb3.append(i16);
                        sb3.append('d');
                        arrayList.add(sb3.toString());
                    }
                } else if (iOrdinal == 4) {
                    i14++;
                }
            }
        }
        long j10 = f4820i.get(this);
        StringBuilder sb4 = new StringBuilder();
        sb4.append(this.f4826d);
        sb4.append('@');
        sb4.append(y.z(this));
        sb4.append("[Pool Size {core = ");
        int i17 = this.f4823a;
        sb4.append(i17);
        sb4.append(", max = ");
        sb4.append(this.f4824b);
        sb4.append("}, Worker States {CPU = ");
        sb4.append(i10);
        sb4.append(", blocking = ");
        sb4.append(i11);
        sb4.append(", parked = ");
        sb4.append(i12);
        sb4.append(", dormant = ");
        sb4.append(i13);
        sb4.append(", terminated = ");
        sb4.append(i14);
        sb4.append("}, running workers queues = ");
        sb4.append(arrayList);
        sb4.append(", global CPU queue size = ");
        sb4.append(this.f4827e.c());
        sb4.append(", global blocking queue size = ");
        sb4.append(this.f4828f.c());
        sb4.append(", Control State {created workers= ");
        sb4.append((int) (2097151 & j10));
        sb4.append(", blocking tasks = ");
        sb4.append((int) ((4398044413952L & j10) >> 21));
        sb4.append(", CPUs acquired = ");
        sb4.append(i17 - ((int) ((j10 & 9223367638808264704L) >> 42)));
        sb4.append("}]");
        return sb4.toString();
    }
}