package p025.p026.p030;

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

/* JADX INFO: renamed from: އ.֏.ၸ.ފ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public final class C1435 {

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public static final AtomicReferenceFieldUpdater f4627 = AtomicReferenceFieldUpdater.newUpdater(C1435.class, Object.class, "lastScheduledTask");

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public static final AtomicIntegerFieldUpdater f4628 = AtomicIntegerFieldUpdater.newUpdater(C1435.class, "producerIndex");

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public static final AtomicIntegerFieldUpdater f4629 = AtomicIntegerFieldUpdater.newUpdater(C1435.class, "consumerIndex");

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public static final AtomicIntegerFieldUpdater f4630 = AtomicIntegerFieldUpdater.newUpdater(C1435.class, "blockingTasksInBuffer");

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final AtomicReferenceArray<AbstractRunnableC1430> f4631 = new AtomicReferenceArray<>(128);
    public volatile Object lastScheduledTask = null;
    public volatile int producerIndex = 0;
    public volatile int consumerIndex = 0;
    public volatile int blockingTasksInBuffer = 0;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final int m2773() {
        return this.producerIndex - this.consumerIndex;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final long m2774(C1435 c1435, boolean z) {
        AbstractRunnableC1430 abstractRunnableC1430;
        do {
            abstractRunnableC1430 = (AbstractRunnableC1430) c1435.lastScheduledTask;
            if (abstractRunnableC1430 == null) {
                return -2L;
            }
            if (z) {
                if (!(abstractRunnableC1430.f4620.mo2772() == 1)) {
                    return -2L;
                }
            }
            if (((C1428) C1433.f4626) == null) {
                throw null;
            }
            long jNanoTime = System.nanoTime() - abstractRunnableC1430.f4619;
            long j = C1433.f4622;
            if (jNanoTime < j) {
                return j - jNanoTime;
            }
        } while (!f4627.compareAndSet(c1435, abstractRunnableC1430, null));
        m2776(abstractRunnableC1430, false);
        return -1L;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final AbstractRunnableC1430 m2775(AbstractRunnableC1430 abstractRunnableC1430) {
        if (abstractRunnableC1430.f4620.mo2772() == 1) {
            f4630.incrementAndGet(this);
        }
        if (m2773() == 127) {
            return abstractRunnableC1430;
        }
        int i = this.producerIndex & 127;
        while (this.f4631.get(i) != null) {
            Thread.yield();
        }
        this.f4631.lazySet(i, abstractRunnableC1430);
        f4628.incrementAndGet(this);
        return null;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final AbstractRunnableC1430 m2776(AbstractRunnableC1430 abstractRunnableC1430, boolean z) {
        if (z) {
            return m2775(abstractRunnableC1430);
        }
        AbstractRunnableC1430 abstractRunnableC14302 = (AbstractRunnableC1430) f4627.getAndSet(this, abstractRunnableC1430);
        if (abstractRunnableC14302 != null) {
            return m2775(abstractRunnableC14302);
        }
        return null;
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final int m2777() {
        return this.lastScheduledTask != null ? m2773() + 1 : m2773();
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public final AbstractRunnableC1430 m2778() {
        AbstractRunnableC1430 abstractRunnableC1430 = (AbstractRunnableC1430) f4627.getAndSet(this, null);
        return abstractRunnableC1430 != null ? abstractRunnableC1430 : m2779();
    }

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public final AbstractRunnableC1430 m2779() {
        AbstractRunnableC1430 andSet;
        while (true) {
            int i = this.consumerIndex;
            if (i - this.producerIndex == 0) {
                return null;
            }
            int i2 = i & 127;
            if (f4629.compareAndSet(this, i, i + 1) && (andSet = this.f4631.getAndSet(i2, null)) != null) {
                if (andSet.f4620.mo2772() == 1) {
                    f4630.decrementAndGet(this);
                }
                return andSet;
            }
        }
    }
}