package p025.p026;

import kotlin.TypeCastException;
import p025.p026.AbstractC1346;
import p025.p026.p027.C1277;
import p025.p026.p027.C1288;
import p402.p403.C6560;

/* JADX INFO: renamed from: އ.֏.ࢠ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public abstract class AbstractC1345 extends AbstractC1323 {

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public long f4492;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public boolean f4493;

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public C1277<AbstractC1339<?>> f4494;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m2669(AbstractC1339<?> abstractC1339) {
        C1277<AbstractC1339<?>> c1277 = this.f4494;
        if (c1277 == null) {
            c1277 = new C1277<>();
            this.f4494 = c1277;
        }
        Object[] objArr = c1277.f4405;
        int i = c1277.f4407;
        objArr[i] = abstractC1339;
        int length = (objArr.length - 1) & (i + 1);
        c1277.f4407 = length;
        int i2 = c1277.f4406;
        if (length == i2) {
            int length2 = objArr.length;
            Object[] objArr2 = new Object[length2 << 1];
            C6560.m9791(objArr, objArr2, 0, i2, 0, 10);
            Object[] objArr3 = c1277.f4405;
            int length3 = objArr3.length;
            int i3 = c1277.f4406;
            C6560.m9791(objArr3, objArr2, length3 - i3, 0, i3, 4);
            c1277.f4405 = objArr2;
            c1277.f4406 = 0;
            c1277.f4407 = length2;
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m2670(boolean z) {
        AbstractC1346.AbstractRunnableC1349 abstractRunnableC1349M2602;
        long jM2671 = this.f4492 - m2671(z);
        this.f4492 = jM2671;
        if (jM2671 > 0 || !this.f4493) {
            return;
        }
        AbstractC1346 abstractC1346 = (AbstractC1346) this;
        C1385 c1385 = C1385.f4539;
        C1385.f4538.set(null);
        abstractC1346._isCompleted = 1;
        while (true) {
            Object obj = abstractC1346._queue;
            if (obj == null) {
                if (AbstractC1346.f4495.compareAndSet(abstractC1346, null, C1352.f4505)) {
                    break;
                }
            } else if (obj instanceof C1288) {
                ((C1288) obj).m2586();
                break;
            } else {
                if (obj == C1352.f4505) {
                    break;
                }
                C1288 c1288 = new C1288(8, true);
                c1288.m2585((Runnable) obj);
                if (AbstractC1346.f4495.compareAndSet(abstractC1346, obj, c1288)) {
                    break;
                }
            }
        }
        while (abstractC1346.m2679() <= 0) {
        }
        long jNanoTime = System.nanoTime();
        while (true) {
            AbstractC1346.C1350 c1350 = (AbstractC1346.C1350) abstractC1346._delayed;
            if (c1350 == null || (abstractRunnableC1349M2602 = c1350.m2602()) == null) {
                return;
            } else {
                RunnableC1330.f4471.m2675(jNanoTime, abstractRunnableC1349M2602);
            }
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final long m2671(boolean z) {
        return z ? 4294967296L : 1L;
    }

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public final void m2672(boolean z) {
        this.f4492 = m2671(z) + this.f4492;
        if (z) {
            return;
        }
        this.f4493 = true;
    }

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public final boolean m2673() {
        return this.f4492 >= m2671(true);
    }

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public final boolean m2674() {
        C1277<AbstractC1339<?>> c1277 = this.f4494;
        if (c1277 == null) {
            return false;
        }
        int i = c1277.f4406;
        Object obj = null;
        if (i != c1277.f4407) {
            Object[] objArr = c1277.f4405;
            Object obj2 = objArr[i];
            objArr[i] = null;
            c1277.f4406 = (i + 1) & (objArr.length - 1);
            if (obj2 == null) {
                throw new TypeCastException("null cannot be cast to non-null type T");
            }
            obj = obj2;
        }
        AbstractC1339 abstractC1339 = (AbstractC1339) obj;
        if (abstractC1339 == null) {
            return false;
        }
        abstractC1339.run();
        return true;
    }
}