package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicLongFieldUpdater;

/* renamed from: ᵭːʚ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C4117 extends Thread {

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f15371 = AtomicIntegerFieldUpdater.newUpdater(C4117.class, "workerCtl$volatile");
    private volatile int indexInArray;
    private volatile Object nextParkedWorker;
    private volatile /* synthetic */ int workerCtl$volatile;

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public boolean f15372;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public final /* synthetic */ ExecutorC1873 f15373;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public int f15374;

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

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public long f15376;

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

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public long f15378;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public int f15379;

    public C4117(ExecutorC1873 executorC1873, int i) {
        this.f15373 = executorC1873;
        setDaemon(true);
        setContextClassLoader(ExecutorC1873.class.getClassLoader());
        this.f15377 = new C3302();
        this.f15375 = new C3057();
        this.f15379 = 4;
        this.nextParkedWorker = ExecutorC1873.f7581;
        int iNanoTime = (int) System.nanoTime();
        this.f15374 = iNanoTime == 0 ? 42 : iNanoTime;
        m9014(i);
    }

    /* JADX WARN: Code restructure failed: missing block: B:122:0x0004, code lost:
    
        continue;
     */
    @Override // java.lang.Thread, java.lang.Runnable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void run() {
        /*
            Method dump skipped, instructions count: 399
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C4117.run():void");
    }

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final AbstractRunnableC2488 m9012() {
        int iM9020 = m9020(2);
        ExecutorC1873 executorC1873 = this.f15373;
        C2174 c2174 = executorC1873.f7583;
        C2174 c21742 = executorC1873.f7585;
        if (iM9020 == 0) {
            AbstractRunnableC2488 abstractRunnableC2488 = (AbstractRunnableC2488) c21742.m4269();
            return abstractRunnableC2488 != null ? abstractRunnableC2488 : (AbstractRunnableC2488) c2174.m4269();
        }
        AbstractRunnableC2488 abstractRunnableC24882 = (AbstractRunnableC2488) c2174.m4269();
        return abstractRunnableC24882 != null ? abstractRunnableC24882 : (AbstractRunnableC2488) c21742.m4269();
    }

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public final void m9013(Object obj) {
        this.nextParkedWorker = obj;
    }

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public final void m9014(int i) {
        StringBuilder sb = new StringBuilder();
        sb.append(this.f15373.f7587);
        sb.append("-worker-");
        sb.append(i == 0 ? "TERMINATED" : String.valueOf(i));
        setName(sb.toString());
        this.indexInArray = i;
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final Object m9015() {
        return this.nextParkedWorker;
    }

    /* renamed from: ᵝᵵᵺ, reason: contains not printable characters */
    public final AbstractRunnableC2488 m9016(int i) {
        AbstractRunnableC2488 abstractRunnableC2488M7686;
        long jM7687;
        AtomicLongFieldUpdater atomicLongFieldUpdater = ExecutorC1873.f7579;
        ExecutorC1873 executorC1873 = this.f15373;
        int i2 = (int) (atomicLongFieldUpdater.get(executorC1873) & 2097151);
        if (i2 < 2) {
            return null;
        }
        int iM9020 = m9020(i2);
        long jMin = Long.MAX_VALUE;
        for (int i3 = 0; i3 < i2; i3++) {
            iM9020++;
            if (iM9020 > i2) {
                iM9020 = 1;
            }
            C4117 c4117 = (C4117) executorC1873.f7582.m2980(iM9020);
            if (c4117 != null && c4117 != this) {
                C3302 c3302 = c4117.f15377;
                c3302.getClass();
                if (i == 3) {
                    abstractRunnableC2488M7686 = c3302.m7688();
                } else {
                    boolean z = i == 1;
                    int i4 = C3302.f12371.get(c3302);
                    int i5 = C3302.f12369.get(c3302);
                    while (i4 != i5 && (!z || C3302.f12367.get(c3302) != 0)) {
                        int i6 = i4 + 1;
                        abstractRunnableC2488M7686 = c3302.m7686(i4, z);
                        if (abstractRunnableC2488M7686 != null) {
                            break;
                        }
                        i4 = i6;
                    }
                    abstractRunnableC2488M7686 = null;
                }
                C3057 c3057 = this.f15375;
                if (abstractRunnableC2488M7686 != null) {
                    c3057.f11710 = abstractRunnableC2488M7686;
                    jM7687 = -1;
                } else {
                    jM7687 = c3302.m7687(i, c3057);
                }
                if (jM7687 == -1) {
                    AbstractRunnableC2488 abstractRunnableC2488 = (AbstractRunnableC2488) c3057.f11710;
                    c3057.f11710 = null;
                    return abstractRunnableC2488;
                }
                if (jM7687 > 0) {
                    jMin = Math.min(jMin, jM7687);
                }
            }
        }
        if (jMin == Long.MAX_VALUE) {
            jMin = 0;
        }
        this.f15376 = jMin;
        return null;
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final AbstractRunnableC2488 m9017(boolean z) {
        AbstractRunnableC2488 abstractRunnableC2488M9012;
        AbstractRunnableC2488 abstractRunnableC2488M90122;
        long j;
        int i = this.f15379;
        ExecutorC1873 executorC1873 = this.f15373;
        C3302 c3302 = this.f15377;
        if (i != 1) {
            AtomicLongFieldUpdater atomicLongFieldUpdater = ExecutorC1873.f7579;
            do {
                j = atomicLongFieldUpdater.get(executorC1873);
                if (((int) ((9223367638808264704L & j) >> 42)) == 0) {
                    AbstractRunnableC2488 abstractRunnableC2488M7691 = c3302.m7691();
                    return (abstractRunnableC2488M7691 == null && (abstractRunnableC2488M7691 = (AbstractRunnableC2488) executorC1873.f7583.m4269()) == null) ? m9016(1) : abstractRunnableC2488M7691;
                }
            } while (!ExecutorC1873.f7579.compareAndSet(executorC1873, j, j - 4398046511104L));
            this.f15379 = 1;
        }
        if (z) {
            boolean z2 = m9020(executorC1873.f7586 * 2) == 0;
            if (z2 && (abstractRunnableC2488M90122 = m9012()) != null) {
                return abstractRunnableC2488M90122;
            }
            c3302.getClass();
            C3302.f12370.getClass();
            AbstractRunnableC2488 abstractRunnableC2488M7688 = (AbstractRunnableC2488) AbstractC3747.m8370(AbstractC3747.f13986, c3302, C3302.f12368, null);
            if (abstractRunnableC2488M7688 == null) {
                abstractRunnableC2488M7688 = c3302.m7688();
            }
            if (abstractRunnableC2488M7688 != null) {
                return abstractRunnableC2488M7688;
            }
            if (!z2 && (abstractRunnableC2488M9012 = m9012()) != null) {
                return abstractRunnableC2488M9012;
            }
        } else {
            AbstractRunnableC2488 abstractRunnableC2488M90123 = m9012();
            if (abstractRunnableC2488M90123 != null) {
                return abstractRunnableC2488M90123;
            }
        }
        return m9016(3);
    }

    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    public final int m9018() {
        return this.indexInArray;
    }

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public final boolean m9019(int i) {
        int i2 = this.f15379;
        boolean z = i2 == 1;
        if (z) {
            ExecutorC1873.f7579.addAndGet(this.f15373, 4398046511104L);
        }
        if (i2 != i) {
            this.f15379 = i;
        }
        return z;
    }

    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final int m9020(int i) {
        int i2 = this.f15374;
        int i3 = i2 ^ (i2 << 13);
        int i4 = i3 ^ (i3 >> 17);
        int i5 = i4 ^ (i4 << 5);
        this.f15374 = i5;
        int i6 = i - 1;
        return (i6 & i) == 0 ? i6 & i5 : (Integer.MAX_VALUE & i5) % i;
    }
}