package kotlinx.coroutines.scheduling;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: loaded from: classes2.dex */
public final class n {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private static final /* synthetic */ AtomicReferenceFieldUpdater f5234b = AtomicReferenceFieldUpdater.newUpdater(n.class, Object.class, "lastScheduledTask");

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5235c = AtomicIntegerFieldUpdater.newUpdater(n.class, "producerIndex");

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5236d = AtomicIntegerFieldUpdater.newUpdater(n.class, "consumerIndex");

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5237e = AtomicIntegerFieldUpdater.newUpdater(n.class, "blockingTasksInBuffer");

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private final AtomicReferenceArray f5238a = new AtomicReferenceArray(128);
    private volatile /* synthetic */ Object lastScheduledTask = null;
    private volatile /* synthetic */ int producerIndex = 0;
    private volatile /* synthetic */ int consumerIndex = 0;
    private volatile /* synthetic */ int blockingTasksInBuffer = 0;

    public static /* synthetic */ i b(n nVar, i iVar, boolean z2, int i2, Object obj) {
        if ((i2 & 2) != 0) {
            z2 = false;
        }
        return nVar.a(iVar, z2);
    }

    private final i c(i iVar) {
        if (iVar.f5226g.i() == 1) {
            f5237e.incrementAndGet(this);
        }
        if (e() == 127) {
            return iVar;
        }
        int i2 = this.producerIndex & 127;
        while (this.f5238a.get(i2) != null) {
            Thread.yield();
        }
        this.f5238a.lazySet(i2, iVar);
        f5235c.incrementAndGet(this);
        return null;
    }

    private final void d(i iVar) {
        if (iVar == null || iVar.f5226g.i() != 1) {
            return;
        }
        f5237e.decrementAndGet(this);
    }

    private final i i() {
        i iVar;
        while (true) {
            int i2 = this.consumerIndex;
            if (i2 - this.producerIndex == 0) {
                return null;
            }
            int i3 = i2 & 127;
            if (f5236d.compareAndSet(this, i2, i2 + 1) && (iVar = (i) this.f5238a.getAndSet(i3, null)) != null) {
                d(iVar);
                return iVar;
            }
        }
    }

    private final boolean j(d dVar) {
        i iVarI = i();
        if (iVarI == null) {
            return false;
        }
        dVar.a(iVarI);
        return true;
    }

    private final long m(n nVar, boolean z2) {
        i iVar;
        do {
            iVar = (i) nVar.lastScheduledTask;
            if (iVar == null) {
                return -2L;
            }
            if (z2 && iVar.f5226g.i() != 1) {
                return -2L;
            }
            long jA = l.f5233f.a() - iVar.f5225b;
            long j2 = l.f5228a;
            if (jA < j2) {
                return j2 - jA;
            }
        } while (!androidx.concurrent.futures.a.a(f5234b, nVar, iVar, null));
        b(this, iVar, false, 2, null);
        return -1L;
    }

    public final i a(i iVar, boolean z2) {
        if (z2) {
            return c(iVar);
        }
        i iVar2 = (i) f5234b.getAndSet(this, iVar);
        if (iVar2 == null) {
            return null;
        }
        return c(iVar2);
    }

    public final int e() {
        return this.producerIndex - this.consumerIndex;
    }

    public final int f() {
        return this.lastScheduledTask != null ? e() + 1 : e();
    }

    public final void g(d dVar) {
        i iVar = (i) f5234b.getAndSet(this, null);
        if (iVar != null) {
            dVar.a(iVar);
        }
        while (j(dVar)) {
        }
    }

    public final i h() {
        i iVar = (i) f5234b.getAndSet(this, null);
        return iVar == null ? i() : iVar;
    }

    public final long k(n nVar) {
        int i2 = nVar.producerIndex;
        AtomicReferenceArray atomicReferenceArray = nVar.f5238a;
        for (int i3 = nVar.consumerIndex; i3 != i2; i3++) {
            int i4 = i3 & 127;
            if (nVar.blockingTasksInBuffer == 0) {
                break;
            }
            i iVar = (i) atomicReferenceArray.get(i4);
            if (iVar != null && iVar.f5226g.i() == 1 && m.a(atomicReferenceArray, i4, iVar, null)) {
                f5237e.decrementAndGet(nVar);
                b(this, iVar, false, 2, null);
                return -1L;
            }
        }
        return m(nVar, true);
    }

    public final long l(n nVar) {
        i iVarI = nVar.i();
        if (iVarI == null) {
            return m(nVar, false);
        }
        b(this, iVarI, false, 2, null);
        return -1L;
    }
}