package defpackage;

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

/* JADX INFO: renamed from: ᵳⁱˑ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4621 extends Thread {

    /* JADX INFO: renamed from: ᵸˆˁ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f17570 = AtomicIntegerFieldUpdater.newUpdater(C4621.class, "workerCtl$volatile");
    private volatile int indexInArray;
    private volatile Object nextParkedWorker;
    private volatile /* synthetic */ int workerCtl$volatile;

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public boolean f17571;

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final C4232 f17572;

    /* JADX INFO: renamed from: ˌᵨʠᵫ, reason: contains not printable characters */
    public final /* synthetic */ ExecutorC2138 f17573;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public int f17574;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final C2761 f17575;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public long f17576;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public long f17577;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public int f17578;

    public C4621(ExecutorC2138 executorC2138, int i) {
        this.f17573 = executorC2138;
        setDaemon(true);
        setContextClassLoader(ExecutorC2138.class.getClassLoader());
        this.f17572 = new C4232();
        this.f17575 = new C2761();
        this.f17574 = 4;
        this.nextParkedWorker = ExecutorC2138.f8466;
        int iNanoTime = (int) System.nanoTime();
        this.f17578 = iNanoTime == 0 ? 42 : iNanoTime;
        m9760(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.
    */
    public final void run() {
        long j;
        loop0: while (true) {
            boolean z = false;
            while (ExecutorC2138.f8468.get(this.f17573) != 1 && this.f17574 != 5) {
                AbstractRunnableC1361 abstractRunnableC1361M9756 = m9756(this.f17571);
                if (abstractRunnableC1361M9756 != null) {
                    this.f17577 = 0L;
                    ExecutorC2138 executorC2138 = this.f17573;
                    this.f17576 = 0L;
                    if (this.f17574 == 3) {
                        this.f17574 = 2;
                    }
                    if (abstractRunnableC1361M9756.f5634) {
                        if (m9753(2) && !executorC2138.m5649() && !executorC2138.m5647(ExecutorC2138.f8469.get(executorC2138))) {
                            executorC2138.m5649();
                        }
                        try {
                            abstractRunnableC1361M9756.run();
                        } catch (Throwable th) {
                            Thread threadCurrentThread = Thread.currentThread();
                            threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, th);
                        }
                        ExecutorC2138.f8469.addAndGet(executorC2138, -2097152L);
                        if (this.f17574 != 5) {
                            this.f17574 = 4;
                        }
                    } else {
                        try {
                            abstractRunnableC1361M9756.run();
                        } catch (Throwable th2) {
                            Thread threadCurrentThread2 = Thread.currentThread();
                            threadCurrentThread2.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread2, th2);
                        }
                    }
                } else {
                    this.f17571 = false;
                    if (this.f17577 == 0) {
                        Object obj = this.nextParkedWorker;
                        C1735 c1735 = ExecutorC2138.f8466;
                        if (obj != c1735) {
                            f17570.set(this, -1);
                            while (this.nextParkedWorker != ExecutorC2138.f8466) {
                                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f17570;
                                if (atomicIntegerFieldUpdater.get(this) == -1) {
                                    ExecutorC2138 executorC21382 = this.f17573;
                                    AtomicIntegerFieldUpdater atomicIntegerFieldUpdater2 = ExecutorC2138.f8468;
                                    if (atomicIntegerFieldUpdater2.get(executorC21382) != 1 && this.f17574 != 5) {
                                        m9753(3);
                                        Thread.interrupted();
                                        if (this.f17576 == 0) {
                                            j = 2097151;
                                            this.f17576 = System.nanoTime() + this.f17573.f8472;
                                        } else {
                                            j = 2097151;
                                        }
                                        LockSupport.parkNanos(this.f17573.f8472);
                                        if (System.nanoTime() - this.f17576 >= 0) {
                                            this.f17576 = 0L;
                                            ExecutorC2138 executorC21383 = this.f17573;
                                            synchronized (executorC21383.f8470) {
                                                try {
                                                    if (!(atomicIntegerFieldUpdater2.get(executorC21383) == 1)) {
                                                        AtomicLongFieldUpdater atomicLongFieldUpdater = ExecutorC2138.f8469;
                                                        if (((int) (atomicLongFieldUpdater.get(executorC21383) & j)) > executorC21383.f8471 && atomicIntegerFieldUpdater.compareAndSet(this, -1, 1)) {
                                                            int i = this.indexInArray;
                                                            m9760(0);
                                                            executorC21383.m5650(this, i, 0);
                                                            int andDecrement = (int) (atomicLongFieldUpdater.getAndDecrement(executorC21383) & j);
                                                            if (andDecrement != i) {
                                                                C4621 c4621 = (C4621) executorC21383.f8470.m7692(andDecrement);
                                                                executorC21383.f8470.m7693(i, c4621);
                                                                c4621.m9760(i);
                                                                executorC21383.m5650(c4621, andDecrement, i);
                                                            }
                                                            executorC21383.f8470.m7693(andDecrement, null);
                                                            this.f17574 = 5;
                                                        }
                                                    }
                                                } catch (Throwable th3) {
                                                    throw th3;
                                                }
                                            }
                                        }
                                    }
                                }
                            }
                        } else {
                            ExecutorC2138 executorC21384 = this.f17573;
                            if (this.nextParkedWorker == c1735) {
                                AtomicLongFieldUpdater atomicLongFieldUpdater2 = ExecutorC2138.f8467;
                                while (true) {
                                    long j2 = atomicLongFieldUpdater2.get(executorC21384);
                                    int i2 = this.indexInArray;
                                    this.nextParkedWorker = executorC21384.f8470.m7692((int) (j2 & 2097151));
                                    ExecutorC2138 executorC21385 = executorC21384;
                                    if (ExecutorC2138.f8467.compareAndSet(executorC21385, j2, ((j2 + 2097152) & (-2097152)) | ((long) i2))) {
                                        break;
                                    } else {
                                        executorC21384 = executorC21385;
                                    }
                                }
                            }
                        }
                    } else if (z) {
                        m9753(3);
                        Thread.interrupted();
                        LockSupport.parkNanos(this.f17577);
                        this.f17577 = 0L;
                    } else {
                        z = true;
                    }
                }
            }
            break loop0;
        }
        m9753(5);
    }

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final int m9752() {
        return this.indexInArray;
    }

    /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */
    public final boolean m9753(int i) {
        int i2 = this.f17574;
        boolean z = i2 == 1;
        if (z) {
            ExecutorC2138.f8469.addAndGet(this.f17573, 4398046511104L);
        }
        if (i2 != i) {
            this.f17574 = i;
        }
        return z;
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final Object m9754() {
        return this.nextParkedWorker;
    }

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9755() {
        int iM9758 = m9758(2);
        ExecutorC2138 executorC2138 = this.f17573;
        C4219 c4219 = executorC2138.f8476;
        C4219 c42192 = executorC2138.f8475;
        if (iM9758 == 0) {
            AbstractRunnableC1361 abstractRunnableC1361 = (AbstractRunnableC1361) c42192.m5674();
            return abstractRunnableC1361 != null ? abstractRunnableC1361 : (AbstractRunnableC1361) c4219.m5674();
        }
        AbstractRunnableC1361 abstractRunnableC13612 = (AbstractRunnableC1361) c4219.m5674();
        return abstractRunnableC13612 != null ? abstractRunnableC13612 : (AbstractRunnableC1361) c42192.m5674();
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9756(boolean z) {
        AbstractRunnableC1361 abstractRunnableC1361M9755;
        AbstractRunnableC1361 abstractRunnableC1361M97552;
        long j;
        int i = this.f17574;
        ExecutorC2138 executorC2138 = this.f17573;
        C4232 c4232 = this.f17572;
        if (i != 1) {
            AtomicLongFieldUpdater atomicLongFieldUpdater = ExecutorC2138.f8469;
            do {
                j = atomicLongFieldUpdater.get(executorC2138);
                if (((int) ((9223367638808264704L & j) >> 42)) == 0) {
                    AbstractRunnableC1361 abstractRunnableC1361M9208 = c4232.m9208();
                    return (abstractRunnableC1361M9208 == null && (abstractRunnableC1361M9208 = (AbstractRunnableC1361) executorC2138.f8476.m5674()) == null) ? m9759(1) : abstractRunnableC1361M9208;
                }
            } while (!ExecutorC2138.f8469.compareAndSet(executorC2138, j, j - 4398046511104L));
            this.f17574 = 1;
        }
        if (z) {
            boolean z2 = m9758(executorC2138.f8471 * 2) == 0;
            if (z2 && (abstractRunnableC1361M97552 = m9755()) != null) {
                return abstractRunnableC1361M97552;
            }
            c4232.getClass();
            C4232.f16141.getClass();
            AbstractRunnableC1361 abstractRunnableC1361M9205 = (AbstractRunnableC1361) AbstractC1929.m5168(AbstractC1929.f7689, c4232, C4232.f16145, null);
            if (abstractRunnableC1361M9205 == null) {
                abstractRunnableC1361M9205 = c4232.m9205();
            }
            if (abstractRunnableC1361M9205 != null) {
                return abstractRunnableC1361M9205;
            }
            if (!z2 && (abstractRunnableC1361M9755 = m9755()) != null) {
                return abstractRunnableC1361M9755;
            }
        } else {
            AbstractRunnableC1361 abstractRunnableC1361M97553 = m9755();
            if (abstractRunnableC1361M97553 != null) {
                return abstractRunnableC1361M97553;
            }
        }
        return m9759(3);
    }

    /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */
    public final void m9757(Object obj) {
        this.nextParkedWorker = obj;
    }

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public final int m9758(int i) {
        int i2 = this.f17578;
        int i3 = i2 ^ (i2 << 13);
        int i4 = i3 ^ (i3 >> 17);
        int i5 = i4 ^ (i4 << 5);
        this.f17578 = i5;
        int i6 = i - 1;
        return (i6 & i) == 0 ? i6 & i5 : (Integer.MAX_VALUE & i5) % i;
    }

    /* JADX INFO: renamed from: ᵻʽᵯ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9759(int i) {
        AbstractRunnableC1361 abstractRunnableC1361M9206;
        long jM9209;
        AtomicLongFieldUpdater atomicLongFieldUpdater = ExecutorC2138.f8469;
        ExecutorC2138 executorC2138 = this.f17573;
        int i2 = (int) (atomicLongFieldUpdater.get(executorC2138) & 2097151);
        if (i2 < 2) {
            return null;
        }
        int iM9758 = m9758(i2);
        long jMin = Long.MAX_VALUE;
        for (int i3 = 0; i3 < i2; i3++) {
            iM9758++;
            if (iM9758 > i2) {
                iM9758 = 1;
            }
            C4621 c4621 = (C4621) executorC2138.f8470.m7692(iM9758);
            if (c4621 != null && c4621 != this) {
                C4232 c4232 = c4621.f17572;
                c4232.getClass();
                if (i == 3) {
                    abstractRunnableC1361M9206 = c4232.m9205();
                } else {
                    boolean z = i == 1;
                    int i4 = C4232.f16144.get(c4232);
                    int i5 = C4232.f16142.get(c4232);
                    while (i4 != i5 && (!z || C4232.f16143.get(c4232) != 0)) {
                        int i6 = i4 + 1;
                        abstractRunnableC1361M9206 = c4232.m9206(i4, z);
                        if (abstractRunnableC1361M9206 != null) {
                            break;
                        }
                        i4 = i6;
                    }
                    abstractRunnableC1361M9206 = null;
                }
                C2761 c2761 = this.f17575;
                if (abstractRunnableC1361M9206 != null) {
                    c2761.f10617 = abstractRunnableC1361M9206;
                    jM9209 = -1;
                } else {
                    jM9209 = c4232.m9209(i, c2761);
                }
                if (jM9209 == -1) {
                    AbstractRunnableC1361 abstractRunnableC1361 = (AbstractRunnableC1361) c2761.f10617;
                    c2761.f10617 = null;
                    return abstractRunnableC1361;
                }
                if (jM9209 > 0) {
                    jMin = Math.min(jMin, jM9209);
                }
            }
        }
        if (jMin == Long.MAX_VALUE) {
            jMin = 0;
        }
        this.f17577 = jMin;
        return null;
    }

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public final void m9760(int i) {
        StringBuilder sb = new StringBuilder();
        sb.append(this.f17573.f8474);
        sb.append("-worker-");
        sb.append(i == 0 ? "TERMINATED" : String.valueOf(i));
        setName(sb.toString());
        this.indexInArray = i;
    }
}