package g.a.p2;

import f.t;
import g.a.l0;
import g.a.m0;
import g.a.n2.b0;
import g.a.n2.y;
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.locks.LockSupport;

/* JADX INFO: compiled from: CoroutineScheduler.kt */
/* JADX INFO: loaded from: classes.dex */
public final class a implements Executor, Closeable {
    private volatile /* synthetic */ int _isTerminated;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final int f4107b;
    volatile /* synthetic */ long controlState;

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

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

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

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

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

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final y<b> f4113k;
    private volatile /* synthetic */ long parkedWorkersStack;
    public static final b0 o = new b0("NOT_IN_STACK");
    private static final /* synthetic */ AtomicLongFieldUpdater l = AtomicLongFieldUpdater.newUpdater(a.class, "parkedWorkersStack");
    static final /* synthetic */ AtomicLongFieldUpdater m = AtomicLongFieldUpdater.newUpdater(a.class, "controlState");
    private static final /* synthetic */ AtomicIntegerFieldUpdater n = AtomicIntegerFieldUpdater.newUpdater(a.class, "_isTerminated");

    /* JADX INFO: renamed from: g.a.p2.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: CoroutineScheduler.kt */
    public /* synthetic */ class C0129a {
        public static final /* synthetic */ int[] a;

        static {
            int[] iArr = new int[c.values().length];
            iArr[c.PARKING.ordinal()] = 1;
            iArr[c.BLOCKING.ordinal()] = 2;
            iArr[c.CPU_ACQUIRED.ordinal()] = 3;
            iArr[c.DORMANT.ordinal()] = 4;
            iArr[c.TERMINATED.ordinal()] = 5;
            a = iArr;
        }
    }

    /* JADX INFO: compiled from: CoroutineScheduler.kt */
    public enum c {
        CPU_ACQUIRED,
        BLOCKING,
        PARKING,
        DORMANT,
        TERMINATED
    }

    public a(int i2, int i3, long j2, String str) {
        this.f4107b = i2;
        this.f4108f = i3;
        this.f4109g = j2;
        this.f4110h = str;
        if (!(i2 >= 1)) {
            throw new IllegalArgumentException(("Core pool size " + this.f4107b + " should be at least 1").toString());
        }
        if (!(this.f4108f >= this.f4107b)) {
            throw new IllegalArgumentException(("Max pool size " + this.f4108f + " should be greater than or equals to core pool size " + this.f4107b).toString());
        }
        if (!(this.f4108f <= 2097150)) {
            throw new IllegalArgumentException(("Max pool size " + this.f4108f + " should not exceed maximal supported number of threads 2097150").toString());
        }
        if (!(this.f4109g > 0)) {
            throw new IllegalArgumentException(("Idle worker keep alive time " + this.f4109g + " must be positive").toString());
        }
        this.f4111i = new d();
        this.f4112j = new d();
        this.parkedWorkersStack = 0L;
        this.f4113k = new y<>(this.f4107b + 1);
        this.controlState = ((long) this.f4107b) << 42;
        this._isTerminated = 0;
    }

    private final boolean B() {
        b bVarM;
        do {
            bVarM = m();
            if (bVarM == null) {
                return false;
            }
        } while (!b.l.compareAndSet(bVarM, -1, 0));
        LockSupport.unpark(bVarM);
        return true;
    }

    private final boolean a(h hVar) {
        return hVar.f4130f.b() == 1 ? this.f4112j.a(hVar) : this.f4111i.a(hVar);
    }

    private final int d() {
        synchronized (this.f4113k) {
            if (isTerminated()) {
                return -1;
            }
            long j2 = this.controlState;
            int i2 = (int) (j2 & 2097151);
            int iA = f.b0.n.a(i2 - ((int) ((j2 & 4398044413952L) >> 21)), 0);
            if (iA >= this.f4107b) {
                return 0;
            }
            if (i2 >= this.f4108f) {
                return 0;
            }
            int i3 = ((int) (this.controlState & 2097151)) + 1;
            if (!(i3 > 0 && this.f4113k.b(i3) == null)) {
                throw new IllegalArgumentException("Failed requirement.".toString());
            }
            b bVar = new b(this, i3);
            this.f4113k.c(i3, bVar);
            if (!(i3 == ((int) (2097151 & m.incrementAndGet(this))))) {
                throw new IllegalArgumentException("Failed requirement.".toString());
            }
            bVar.start();
            return iA + 1;
        }
    }

    private final b g() {
        Thread threadCurrentThread = Thread.currentThread();
        b bVar = threadCurrentThread instanceof b ? (b) threadCurrentThread : null;
        if (bVar == null || !f.z.d.k.a(a.this, this)) {
            return null;
        }
        return bVar;
    }

    public static /* synthetic */ void j(a aVar, Runnable runnable, i iVar, boolean z, int i2, Object obj) {
        if ((i2 & 2) != 0) {
            iVar = l.f4136f;
        }
        if ((i2 & 4) != 0) {
            z = false;
        }
        aVar.h(runnable, iVar, z);
    }

    private final int k(b bVar) {
        Object objH = bVar.h();
        while (objH != o) {
            if (objH == null) {
                return 0;
            }
            b bVar2 = (b) objH;
            int iG = bVar2.g();
            if (iG != 0) {
                return iG;
            }
            objH = bVar2.h();
        }
        return -1;
    }

    private final b m() {
        while (true) {
            long j2 = this.parkedWorkersStack;
            b bVarB = this.f4113k.b((int) (2097151 & j2));
            if (bVarB == null) {
                return null;
            }
            long j3 = (2097152 + j2) & (-2097152);
            int iK = k(bVarB);
            if (iK >= 0 && l.compareAndSet(this, j2, ((long) iK) | j3)) {
                bVarB.p(o);
                return bVarB;
            }
        }
    }

    private final void r(boolean z) {
        long jAddAndGet = m.addAndGet(this, 2097152L);
        if (z || B() || x(jAddAndGet)) {
            return;
        }
        B();
    }

    private final h w(b bVar, h hVar, boolean z) {
        if (bVar == null || bVar.f4115f == c.TERMINATED) {
            return hVar;
        }
        if (hVar.f4130f.b() == 0 && bVar.f4115f == c.BLOCKING) {
            return hVar;
        }
        bVar.f4119j = true;
        return bVar.f4114b.a(hVar, z);
    }

    private final boolean x(long j2) {
        if (f.b0.n.a(((int) (2097151 & j2)) - ((int) ((j2 & 4398044413952L) >> 21)), 0) < this.f4107b) {
            int iD = d();
            if (iD == 1 && this.f4107b > 1) {
                d();
            }
            if (iD > 0) {
                return true;
            }
        }
        return false;
    }

    static /* synthetic */ boolean y(a aVar, long j2, int i2, Object obj) {
        if ((i2 & 1) != 0) {
            j2 = aVar.controlState;
        }
        return aVar.x(j2);
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public void close() throws InterruptedException {
        q(10000L);
    }

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

    public final h f(Runnable runnable, i iVar) {
        long jA = l.f4135e.a();
        if (!(runnable instanceof h)) {
            return new k(runnable, jA, iVar);
        }
        h hVar = (h) runnable;
        hVar.f4129b = jA;
        hVar.f4130f = iVar;
        return hVar;
    }

    public final void h(Runnable runnable, i iVar, boolean z) {
        g.a.b bVarA = g.a.c.a();
        if (bVarA != null) {
            bVarA.d();
        }
        h hVarF = f(runnable, iVar);
        b bVarG = g();
        h hVarW = w(bVarG, hVarF, z);
        if (hVarW != null && !a(hVarW)) {
            throw new RejectedExecutionException(this.f4110h + " was terminated");
        }
        boolean z2 = z && bVarG != null;
        if (hVarF.f4130f.b() != 0) {
            r(z2);
        } else {
            if (z2) {
                return;
            }
            u();
        }
    }

    /* JADX WARN: Type inference failed for: r0v0, types: [boolean, int] */
    public final boolean isTerminated() {
        return this._isTerminated;
    }

    public final boolean n(b bVar) {
        long j2;
        long j3;
        int iG;
        if (bVar.h() != o) {
            return false;
        }
        do {
            j2 = this.parkedWorkersStack;
            int i2 = (int) (2097151 & j2);
            j3 = (2097152 + j2) & (-2097152);
            iG = bVar.g();
            if (l0.a()) {
                if (!(iG != 0)) {
                    throw new AssertionError();
                }
            }
            bVar.p(this.f4113k.b(i2));
        } while (!l.compareAndSet(this, j2, ((long) iG) | j3));
        return true;
    }

    public final void o(b bVar, int i2, int i3) {
        while (true) {
            long j2 = this.parkedWorkersStack;
            int iK = (int) (2097151 & j2);
            long j3 = (2097152 + j2) & (-2097152);
            if (iK == i2) {
                iK = i3 == 0 ? k(bVar) : i3;
            }
            if (iK >= 0 && l.compareAndSet(this, j2, j3 | ((long) iK))) {
                return;
            }
        }
    }

    public final void p(h hVar) {
        try {
            hVar.run();
        } catch (Throwable th) {
            try {
                Thread threadCurrentThread = Thread.currentThread();
                threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, th);
                g.a.b bVarA = g.a.c.a();
                if (bVarA == null) {
                }
            } finally {
                g.a.b bVarA2 = g.a.c.a();
                if (bVarA2 != null) {
                    bVarA2.e();
                }
            }
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:34:0x006d  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void q(long r9) throws java.lang.InterruptedException {
        /*
            r8 = this;
            java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = g.a.p2.a.n
            r1 = 0
            r2 = 1
            boolean r0 = r0.compareAndSet(r8, r1, r2)
            if (r0 != 0) goto Lb
            return
        Lb:
            g.a.p2.a$b r0 = r8.g()
            g.a.n2.y<g.a.p2.a$b> r3 = r8.f4113k
            monitor-enter(r3)
            long r4 = r8.controlState     // Catch: java.lang.Throwable -> Lb3
            r6 = 2097151(0x1fffff, double:1.0361303E-317)
            long r4 = r4 & r6
            int r4 = (int) r4
            monitor-exit(r3)
            if (r2 > r4) goto L5b
            r3 = r2
        L1d:
            g.a.n2.y<g.a.p2.a$b> r5 = r8.f4113k
            java.lang.Object r5 = r5.b(r3)
            f.z.d.k.c(r5)
            g.a.p2.a$b r5 = (g.a.p2.a.b) r5
            if (r5 == r0) goto L56
        L2a:
            boolean r6 = r5.isAlive()
            if (r6 == 0) goto L37
            java.util.concurrent.locks.LockSupport.unpark(r5)
            r5.join(r9)
            goto L2a
        L37:
            g.a.p2.a$c r6 = r5.f4115f
            boolean r7 = g.a.l0.a()
            if (r7 == 0) goto L4f
            g.a.p2.a$c r7 = g.a.p2.a.c.TERMINATED
            if (r6 != r7) goto L45
            r6 = r2
            goto L46
        L45:
            r6 = r1
        L46:
            if (r6 == 0) goto L49
            goto L4f
        L49:
            java.lang.AssertionError r9 = new java.lang.AssertionError
            r9.<init>()
            throw r9
        L4f:
            g.a.p2.n r5 = r5.f4114b
            g.a.p2.d r6 = r8.f4112j
            r5.g(r6)
        L56:
            if (r3 == r4) goto L5b
            int r3 = r3 + 1
            goto L1d
        L5b:
            g.a.p2.d r9 = r8.f4112j
            r9.b()
            g.a.p2.d r9 = r8.f4111i
            r9.b()
        L65:
            if (r0 == 0) goto L6d
            g.a.p2.h r9 = r0.f(r2)
            if (r9 != 0) goto Laf
        L6d:
            g.a.p2.d r9 = r8.f4111i
            java.lang.Object r9 = r9.d()
            g.a.p2.h r9 = (g.a.p2.h) r9
            if (r9 != 0) goto Laf
            g.a.p2.d r9 = r8.f4112j
            java.lang.Object r9 = r9.d()
            g.a.p2.h r9 = (g.a.p2.h) r9
            if (r9 != 0) goto Laf
            if (r0 == 0) goto L88
            g.a.p2.a$c r9 = g.a.p2.a.c.TERMINATED
            r0.s(r9)
        L88:
            boolean r9 = g.a.l0.a()
            if (r9 == 0) goto La8
            long r9 = r8.controlState
            r3 = 9223367638808264704(0x7ffffc0000000000, double:NaN)
            long r9 = r9 & r3
            r0 = 42
            long r9 = r9 >> r0
            int r9 = (int) r9
            int r10 = r8.f4107b
            if (r9 != r10) goto L9f
            r1 = r2
        L9f:
            if (r1 == 0) goto La2
            goto La8
        La2:
            java.lang.AssertionError r9 = new java.lang.AssertionError
            r9.<init>()
            throw r9
        La8:
            r9 = 0
            r8.parkedWorkersStack = r9
            r8.controlState = r9
            return
        Laf:
            r8.p(r9)
            goto L65
        Lb3:
            r9 = move-exception
            monitor-exit(r3)
            throw r9
        */
        throw new UnsupportedOperationException("Method not decompiled: g.a.p2.a.q(long):void");
    }

    public String toString() {
        ArrayList arrayList = new ArrayList();
        int iA = this.f4113k.a();
        int i2 = 0;
        int i3 = 0;
        int i4 = 0;
        int i5 = 0;
        int i6 = 0;
        for (int i7 = 1; i7 < iA; i7++) {
            b bVarB = this.f4113k.b(i7);
            if (bVarB != null) {
                int iF = bVarB.f4114b.f();
                int i8 = C0129a.a[bVarB.f4115f.ordinal()];
                if (i8 == 1) {
                    i4++;
                } else if (i8 == 2) {
                    i3++;
                    StringBuilder sb = new StringBuilder();
                    sb.append(iF);
                    sb.append('b');
                    arrayList.add(sb.toString());
                } else if (i8 == 3) {
                    i2++;
                    StringBuilder sb2 = new StringBuilder();
                    sb2.append(iF);
                    sb2.append('c');
                    arrayList.add(sb2.toString());
                } else if (i8 == 4) {
                    i5++;
                    if (iF > 0) {
                        StringBuilder sb3 = new StringBuilder();
                        sb3.append(iF);
                        sb3.append('d');
                        arrayList.add(sb3.toString());
                    }
                } else if (i8 == 5) {
                    i6++;
                }
            }
        }
        long j2 = this.controlState;
        return this.f4110h + '@' + m0.b(this) + "[Pool Size {core = " + this.f4107b + ", max = " + this.f4108f + "}, Worker States {CPU = " + i2 + ", blocking = " + i3 + ", parked = " + i4 + ", dormant = " + i5 + ", terminated = " + i6 + "}, running workers queues = " + arrayList + ", global CPU queue size = " + this.f4111i.c() + ", global blocking queue size = " + this.f4112j.c() + ", Control State {created workers= " + ((int) (2097151 & j2)) + ", blocking tasks = " + ((int) ((4398044413952L & j2) >> 21)) + ", CPUs acquired = " + (this.f4107b - ((int) ((9223367638808264704L & j2) >> 42))) + "}]";
    }

    public final void u() {
        if (B() || y(this, 0L, 1, null)) {
            return;
        }
        B();
    }

    /* JADX INFO: compiled from: CoroutineScheduler.kt */
    public final class b extends Thread {
        static final /* synthetic */ AtomicIntegerFieldUpdater l = AtomicIntegerFieldUpdater.newUpdater(b.class, "workerCtl");

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

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

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        private long f4116g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        private long f4117h;

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        private int f4118i;
        private volatile int indexInArray;

        /* JADX INFO: renamed from: j, reason: collision with root package name */
        public boolean f4119j;
        private volatile Object nextParkedWorker;
        volatile /* synthetic */ int workerCtl;

        private b() {
            setDaemon(true);
            this.f4114b = new n();
            this.f4115f = c.DORMANT;
            this.workerCtl = 0;
            this.nextParkedWorker = a.o;
            this.f4118i = f.a0.c.f3895b.b();
        }

        private final void b(int i2) {
            if (i2 == 0) {
                return;
            }
            a.m.addAndGet(a.this, -2097152L);
            c cVar = this.f4115f;
            if (cVar != c.TERMINATED) {
                if (l0.a()) {
                    if (!(cVar == c.BLOCKING)) {
                        throw new AssertionError();
                    }
                }
                this.f4115f = c.DORMANT;
            }
        }

        private final void c(int i2) {
            if (i2 != 0 && s(c.BLOCKING)) {
                a.this.u();
            }
        }

        private final void d(h hVar) {
            int iB = hVar.f4130f.b();
            i(iB);
            c(iB);
            a.this.p(hVar);
            b(iB);
        }

        private final h e(boolean z) {
            h hVarM;
            h hVarM2;
            if (z) {
                boolean z2 = k(a.this.f4107b * 2) == 0;
                if (z2 && (hVarM2 = m()) != null) {
                    return hVarM2;
                }
                h hVarH = this.f4114b.h();
                if (hVarH != null) {
                    return hVarH;
                }
                if (!z2 && (hVarM = m()) != null) {
                    return hVarM;
                }
            } else {
                h hVarM3 = m();
                if (hVarM3 != null) {
                    return hVarM3;
                }
            }
            return t(false);
        }

        private final void i(int i2) {
            this.f4116g = 0L;
            if (this.f4115f == c.PARKING) {
                if (l0.a()) {
                    if (!(i2 == 1)) {
                        throw new AssertionError();
                    }
                }
                this.f4115f = c.BLOCKING;
            }
        }

        private final boolean j() {
            return this.nextParkedWorker != a.o;
        }

        private final void l() {
            if (this.f4116g == 0) {
                this.f4116g = System.nanoTime() + a.this.f4109g;
            }
            LockSupport.parkNanos(a.this.f4109g);
            if (System.nanoTime() - this.f4116g >= 0) {
                this.f4116g = 0L;
                u();
            }
        }

        private final h m() {
            if (k(2) == 0) {
                h hVarD = a.this.f4111i.d();
                return hVarD != null ? hVarD : a.this.f4112j.d();
            }
            h hVarD2 = a.this.f4112j.d();
            return hVarD2 != null ? hVarD2 : a.this.f4111i.d();
        }

        private final void n() {
            loop0: while (true) {
                boolean z = false;
                while (!a.this.isTerminated() && this.f4115f != c.TERMINATED) {
                    h hVarF = f(this.f4119j);
                    if (hVarF != null) {
                        this.f4117h = 0L;
                        d(hVarF);
                    } else {
                        this.f4119j = false;
                        if (this.f4117h == 0) {
                            r();
                        } else if (z) {
                            s(c.PARKING);
                            Thread.interrupted();
                            LockSupport.parkNanos(this.f4117h);
                            this.f4117h = 0L;
                        } else {
                            z = true;
                        }
                    }
                }
                break loop0;
            }
            s(c.TERMINATED);
        }

        private final boolean q() {
            boolean z;
            if (this.f4115f != c.CPU_ACQUIRED) {
                a aVar = a.this;
                while (true) {
                    long j2 = aVar.controlState;
                    if (((int) ((9223367638808264704L & j2) >> 42)) == 0) {
                        z = false;
                        break;
                    }
                    if (a.m.compareAndSet(aVar, j2, j2 - 4398046511104L)) {
                        z = true;
                        break;
                    }
                }
                if (!z) {
                    return false;
                }
                this.f4115f = c.CPU_ACQUIRED;
            }
            return true;
        }

        private final void r() {
            if (!j()) {
                a.this.n(this);
                return;
            }
            if (l0.a()) {
                if (!(this.f4114b.f() == 0)) {
                    throw new AssertionError();
                }
            }
            this.workerCtl = -1;
            while (j() && this.workerCtl == -1 && !a.this.isTerminated() && this.f4115f != c.TERMINATED) {
                s(c.PARKING);
                Thread.interrupted();
                l();
            }
        }

        private final h t(boolean z) {
            if (l0.a()) {
                if (!(this.f4114b.f() == 0)) {
                    throw new AssertionError();
                }
            }
            int i2 = (int) (a.this.controlState & 2097151);
            if (i2 < 2) {
                return null;
            }
            int iK = k(i2);
            a aVar = a.this;
            long jMin = Long.MAX_VALUE;
            for (int i3 = 0; i3 < i2; i3++) {
                iK++;
                if (iK > i2) {
                    iK = 1;
                }
                b bVarB = aVar.f4113k.b(iK);
                if (bVarB != null && bVarB != this) {
                    if (l0.a()) {
                        if (!(this.f4114b.f() == 0)) {
                            throw new AssertionError();
                        }
                    }
                    long jK = z ? this.f4114b.k(bVarB.f4114b) : this.f4114b.l(bVarB.f4114b);
                    if (jK == -1) {
                        return this.f4114b.h();
                    }
                    if (jK > 0) {
                        jMin = Math.min(jMin, jK);
                    }
                }
            }
            if (jMin == Long.MAX_VALUE) {
                jMin = 0;
            }
            this.f4117h = jMin;
            return null;
        }

        private final void u() {
            a aVar = a.this;
            synchronized (aVar.f4113k) {
                if (aVar.isTerminated()) {
                    return;
                }
                if (((int) (aVar.controlState & 2097151)) <= aVar.f4107b) {
                    return;
                }
                if (l.compareAndSet(this, -1, 1)) {
                    int i2 = this.indexInArray;
                    o(0);
                    aVar.o(this, i2, 0);
                    int andDecrement = (int) (a.m.getAndDecrement(aVar) & 2097151);
                    if (andDecrement != i2) {
                        b bVarB = aVar.f4113k.b(andDecrement);
                        f.z.d.k.c(bVarB);
                        b bVar = bVarB;
                        aVar.f4113k.c(i2, bVar);
                        bVar.o(i2);
                        aVar.o(bVar, andDecrement, i2);
                    }
                    aVar.f4113k.c(andDecrement, null);
                    t tVar = t.a;
                    this.f4115f = c.TERMINATED;
                }
            }
        }

        public final h f(boolean z) {
            h hVarD;
            if (q()) {
                return e(z);
            }
            if (!z || (hVarD = this.f4114b.h()) == null) {
                hVarD = a.this.f4112j.d();
            }
            return hVarD == null ? t(true) : hVarD;
        }

        public final int g() {
            return this.indexInArray;
        }

        public final Object h() {
            return this.nextParkedWorker;
        }

        public final int k(int i2) {
            int i3 = this.f4118i;
            int i4 = i3 ^ (i3 << 13);
            int i5 = i4 ^ (i4 >> 17);
            int i6 = i5 ^ (i5 << 5);
            this.f4118i = i6;
            int i7 = i2 - 1;
            return (i7 & i2) == 0 ? i6 & i7 : (i6 & Integer.MAX_VALUE) % i2;
        }

        public final void o(int i2) {
            StringBuilder sb = new StringBuilder();
            sb.append(a.this.f4110h);
            sb.append("-worker-");
            sb.append(i2 == 0 ? "TERMINATED" : String.valueOf(i2));
            setName(sb.toString());
            this.indexInArray = i2;
        }

        public final void p(Object obj) {
            this.nextParkedWorker = obj;
        }

        @Override // java.lang.Thread, java.lang.Runnable
        public void run() {
            n();
        }

        public final boolean s(c cVar) {
            c cVar2 = this.f4115f;
            boolean z = cVar2 == c.CPU_ACQUIRED;
            if (z) {
                a.m.addAndGet(a.this, 4398046511104L);
            }
            if (cVar2 != cVar) {
                this.f4115f = cVar;
            }
            return z;
        }

        public b(a aVar, int i2) {
            this();
            o(i2);
        }
    }
}