package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;
import sun.misc.Unsafe;

/* JADX INFO: renamed from: ᵥᵧᵤ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public abstract class AbstractC3520 extends AbstractC4712 implements InterfaceC4129 {

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f13520;

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

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f13522 = AtomicReferenceFieldUpdater.newUpdater(AbstractC3520.class, Object.class, "_queue$volatile");

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f13523;

    /* JADX INFO: renamed from: ᵸˆˁ, reason: contains not printable characters */
    public static final /* synthetic */ long f13524;
    private volatile /* synthetic */ Object _delayed$volatile;
    private volatile /* synthetic */ int _isCompleted$volatile;
    private volatile /* synthetic */ Object _queue$volatile;

    static {
        Unsafe unsafe = AbstractC1929.f7689;
        f13524 = unsafe.objectFieldOffset(AbstractC3520.class.getDeclaredField("_queue$volatile"));
        f13523 = AtomicReferenceFieldUpdater.newUpdater(AbstractC3520.class, Object.class, "_delayed$volatile");
        f13521 = unsafe.objectFieldOffset(AbstractC3520.class.getDeclaredField("_delayed$volatile"));
        f13520 = AtomicIntegerFieldUpdater.newUpdater(AbstractC3520.class, "_isCompleted$volatile");
    }

    @Override // defpackage.AbstractC4712
    public void shutdown() {
        AbstractC2412.f9406.set(null);
        f13520.set(this, 1);
        m8033();
        while (mo8024() <= 0) {
        }
        m8023();
    }

    /* JADX INFO: renamed from: ʿᵯᴵ, reason: contains not printable characters */
    public void mo8020(long j, AbstractRunnableC2630 abstractRunnableC2630) {
        RunnableC4323.f16461.m8034(j, abstractRunnableC2630);
    }

    /* JADX INFO: renamed from: ˆˀᵯ, reason: contains not printable characters */
    public final long m8021() {
        AbstractRunnableC2630 abstractRunnableC2630;
        C0920 c0920 = this.f17953;
        if (((c0920 == null || c0920.isEmpty()) ? Long.MAX_VALUE : 0L) != 0) {
            f13522.getClass();
            Unsafe unsafe = AbstractC1929.f7689;
            Object objectVolatile = unsafe.getObjectVolatile(this, f13524);
            if (objectVolatile != null) {
                if (objectVolatile instanceof C3410) {
                    long j = C3410.f13136.get((C3410) objectVolatile);
                    if (((int) (1073741823 & j)) != ((int) ((j & 1152921503533105152L) >> 30))) {
                        return 0L;
                    }
                } else if (objectVolatile == AbstractC0979.f4278) {
                    return Long.MAX_VALUE;
                }
            }
            f13523.getClass();
            C5573 c5573 = (C5573) unsafe.getObjectVolatile(this, f13521);
            if (c5573 != null) {
                synchronized (c5573) {
                    AbstractRunnableC2630[] abstractRunnableC2630Arr = c5573.f2031;
                    abstractRunnableC2630 = abstractRunnableC2630Arr != null ? abstractRunnableC2630Arr[0] : null;
                }
                if (abstractRunnableC2630 != null) {
                    long jNanoTime = abstractRunnableC2630.f10229 - System.nanoTime();
                    if (jNanoTime >= 0) {
                        return jNanoTime;
                    }
                }
            }
            return Long.MAX_VALUE;
        }
        return 0L;
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈᵲᵢ */
    public InterfaceC0083 mo7668(long j, Runnable runnable, InterfaceC3822 interfaceC3822) {
        return AbstractC4340.f16524.mo7668(j, runnable, interfaceC3822);
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈⁱᵡ */
    public final void mo7669(long j, C3453 c3453) {
        long j2 = j > 0 ? j >= 9223372036854L ? Long.MAX_VALUE : 1000000 * j : 0L;
        if (j2 < 4611686018427387903L) {
            long jNanoTime = System.nanoTime();
            C2910 c2910 = new C2910(this, j2 + jNanoTime, c3453);
            m8034(jNanoTime, c2910);
            c3453.m7886(new C1780(2, c2910));
        }
    }

    /* JADX INFO: renamed from: ˏʽˊᵰ, reason: contains not printable characters */
    public void mo8022(Runnable runnable) {
        m8031();
        if (!m8029(runnable)) {
            RunnableC4323.f16461.mo8022(runnable);
            return;
        }
        Thread threadMo8025 = mo8025();
        if (Thread.currentThread() != threadMo8025) {
            LockSupport.unpark(threadMo8025);
        }
    }

    /* JADX INFO: renamed from: ᵕᵜʽᵰ, reason: contains not printable characters */
    public final void m8023() {
        AbstractRunnableC2630 abstractRunnableC2630M1572;
        long jNanoTime = System.nanoTime();
        while (true) {
            f13523.getClass();
            C5573 c5573 = (C5573) AbstractC1929.f7689.getObjectVolatile(this, f13521);
            if (c5573 == null) {
                return;
            }
            synchronized (c5573) {
                abstractRunnableC2630M1572 = C0323.f2030.get(c5573) > 0 ? c5573.m1572(0) : null;
            }
            if (abstractRunnableC2630M1572 == null) {
                return;
            } else {
                mo8020(jNanoTime, abstractRunnableC2630M1572);
            }
        }
    }

    @Override // defpackage.AbstractC4712
    /* JADX INFO: renamed from: ᵘᵝ, reason: contains not printable characters */
    public final long mo8024() {
        if (m9860()) {
            return 0L;
        }
        m8031();
        Runnable runnableM8030 = m8030();
        if (runnableM8030 == null) {
            return m8021();
        }
        runnableM8030.run();
        return 0L;
    }

    /* JADX INFO: renamed from: ᵚᵹᵔᵜ, reason: contains not printable characters */
    public abstract Thread mo8025();

    @Override // defpackage.AbstractC2071
    /* JADX INFO: renamed from: ᵜᵤ */
    public final void mo2301(InterfaceC3822 interfaceC3822, Runnable runnable) {
        mo8022(runnable);
    }

    /* JADX INFO: renamed from: ᵟᵴᵥ, reason: contains not printable characters */
    public final void m8026() {
        f13522.getClass();
        Unsafe unsafe = AbstractC1929.f7689;
        unsafe.putObjectVolatile(this, f13524, (Object) null);
        f13523.getClass();
        unsafe.putObjectVolatile(this, f13521, (Object) null);
    }

    /* JADX INFO: renamed from: ᵠᵚˀᵫ, reason: contains not printable characters */
    public final boolean m8027(AbstractRunnableC2630 abstractRunnableC2630) {
        f13523.getClass();
        C5573 c5573 = (C5573) AbstractC1929.f7689.getObjectVolatile(this, f13521);
        if (c5573 != null) {
            synchronized (c5573) {
                AbstractRunnableC2630[] abstractRunnableC2630Arr = c5573.f2031;
                abstractRunnableC2630 = abstractRunnableC2630Arr != null ? abstractRunnableC2630Arr[0] : null;
            }
        }
        return abstractRunnableC2630 == abstractRunnableC2630;
    }

    /* JADX INFO: renamed from: ᵠᵲˁ, reason: contains not printable characters */
    public final int m8028(long j, AbstractRunnableC2630 abstractRunnableC2630) {
        AbstractC3520 abstractC3520;
        Unsafe unsafe;
        if (f13520.get(this) == 1) {
            return 1;
        }
        f13523.getClass();
        Unsafe unsafe2 = AbstractC1929.f7689;
        long j2 = f13521;
        C5573 c5573 = (C5573) unsafe2.getObjectVolatile(this, j2);
        if (c5573 == null) {
            C5573 c55732 = new C5573();
            c55732.f21026 = j;
            while (true) {
                unsafe = AbstractC1929.f7689;
                abstractC3520 = this;
                if (unsafe.compareAndSwapObject(abstractC3520, f13521, (Object) null, c55732) || unsafe.getObjectVolatile(abstractC3520, j2) != null) {
                    break;
                }
                this = abstractC3520;
            }
            c5573 = (C5573) unsafe.getObjectVolatile(abstractC3520, j2);
        } else {
            abstractC3520 = this;
        }
        return abstractRunnableC2630.m6395(j, c5573, abstractC3520);
    }

    /* JADX INFO: renamed from: ᵧᵢᵴᵸ, reason: contains not printable characters */
    public final boolean m8029(Runnable runnable) {
        Unsafe unsafe;
        Unsafe unsafe2;
        Unsafe unsafe3;
        loop0: while (true) {
            f13522.getClass();
            Unsafe unsafe4 = AbstractC1929.f7689;
            long j = f13524;
            Object objectVolatile = unsafe4.getObjectVolatile(this, j);
            if (f13520.get(this) == 1) {
                return false;
            }
            if (objectVolatile == null) {
                do {
                    unsafe = AbstractC1929.f7689;
                    if (unsafe.compareAndSwapObject(this, f13524, (Object) null, runnable)) {
                        break loop0;
                    }
                } while (unsafe.getObjectVolatile(this, j) == null);
            } else if (objectVolatile instanceof C3410) {
                C3410 c3410 = (C3410) objectVolatile;
                int iM7812 = c3410.m7812(runnable);
                if (iM7812 == 0) {
                    break;
                }
                if (iM7812 == 1) {
                    C3410 c3410M7813 = c3410.m7813();
                    do {
                        unsafe2 = AbstractC1929.f7689;
                        if (unsafe2.compareAndSwapObject(this, f13524, objectVolatile, c3410M7813)) {
                            break;
                        }
                    } while (unsafe2.getObjectVolatile(this, j) == objectVolatile);
                } else if (iM7812 == 2) {
                    return false;
                }
            } else {
                if (objectVolatile == AbstractC0979.f4278) {
                    return false;
                }
                C3410 c34102 = new C3410(8, true);
                c34102.m7812((Runnable) objectVolatile);
                c34102.m7812(runnable);
                do {
                    unsafe3 = AbstractC1929.f7689;
                    if (unsafe3.compareAndSwapObject(this, f13524, objectVolatile, c34102)) {
                        break loop0;
                    }
                } while (unsafe3.getObjectVolatile(this, j) == objectVolatile);
            }
        }
        return true;
    }

    /* JADX INFO: renamed from: ᵮᵟᵡ, reason: contains not printable characters */
    public final Runnable m8030() {
        AbstractC3520 abstractC3520;
        Unsafe unsafe;
        while (true) {
            f13522.getClass();
            Unsafe unsafe2 = AbstractC1929.f7689;
            long j = f13524;
            Object objectVolatile = unsafe2.getObjectVolatile(this, j);
            if (objectVolatile == null) {
                return null;
            }
            if (objectVolatile instanceof C3410) {
                C3410 c3410 = (C3410) objectVolatile;
                Object objM7811 = c3410.m7811();
                if (objM7811 != C3410.f13135) {
                    return (Runnable) objM7811;
                }
                C3410 c3410M7813 = c3410.m7813();
                while (true) {
                    Unsafe unsafe3 = AbstractC1929.f7689;
                    abstractC3520 = this;
                    if (!unsafe3.compareAndSwapObject(abstractC3520, f13524, objectVolatile, c3410M7813) && unsafe3.getObjectVolatile(abstractC3520, j) == objectVolatile) {
                        this = abstractC3520;
                    }
                }
            } else {
                abstractC3520 = this;
                if (objectVolatile == AbstractC0979.f4278) {
                    return null;
                }
                do {
                    unsafe = AbstractC1929.f7689;
                    if (unsafe.compareAndSwapObject(abstractC3520, f13524, objectVolatile, (Object) null)) {
                        return (Runnable) objectVolatile;
                    }
                } while (unsafe.getObjectVolatile(abstractC3520, j) == objectVolatile);
            }
            this = abstractC3520;
        }
    }

    /* JADX INFO: renamed from: ᵯˇ, reason: contains not printable characters */
    public final void m8031() {
        AbstractRunnableC2630 abstractRunnableC2630M1572;
        f13523.getClass();
        C5573 c5573 = (C5573) AbstractC1929.f7689.getObjectVolatile(this, f13521);
        if (c5573 == null || C0323.f2030.get(c5573) == 0) {
            return;
        }
        long jNanoTime = System.nanoTime();
        do {
            synchronized (c5573) {
                try {
                    AbstractRunnableC2630[] abstractRunnableC2630Arr = c5573.f2031;
                    abstractRunnableC2630M1572 = null;
                    AbstractRunnableC2630 abstractRunnableC2630 = abstractRunnableC2630Arr != null ? abstractRunnableC2630Arr[0] : null;
                    if (abstractRunnableC2630 != null) {
                        if (jNanoTime - abstractRunnableC2630.f10229 >= 0 ? m8029(abstractRunnableC2630) : false) {
                            abstractRunnableC2630M1572 = c5573.m1572(0);
                        }
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        } while (abstractRunnableC2630M1572 != null);
    }

    /* JADX INFO: renamed from: ᵱᵭ, reason: contains not printable characters */
    public final boolean m8032() {
        C0920 c0920 = this.f17953;
        if (c0920 != null ? c0920.isEmpty() : true) {
            f13523.getClass();
            Unsafe unsafe = AbstractC1929.f7689;
            C5573 c5573 = (C5573) unsafe.getObjectVolatile(this, f13521);
            if (c5573 != null && C0323.f2030.get(c5573) != 0) {
                return false;
            }
            f13522.getClass();
            Object objectVolatile = unsafe.getObjectVolatile(this, f13524);
            if (objectVolatile != null) {
                if (objectVolatile instanceof C3410) {
                    long j = C3410.f13136.get((C3410) objectVolatile);
                    return ((int) (1073741823 & j)) == ((int) ((j & 1152921503533105152L) >> 30));
                }
                if (objectVolatile == AbstractC0979.f4278) {
                }
            }
            return true;
        }
        return false;
    }

    /* JADX INFO: renamed from: ᵹʾᵢᵯ, reason: contains not printable characters */
    public final void m8033() {
        AbstractC3520 abstractC3520;
        Unsafe unsafe;
        while (true) {
            f13522.getClass();
            Unsafe unsafe2 = AbstractC1929.f7689;
            long j = f13524;
            Object objectVolatile = unsafe2.getObjectVolatile(this, j);
            C1735 c1735 = AbstractC0979.f4278;
            if (objectVolatile == null) {
                while (true) {
                    Unsafe unsafe3 = AbstractC1929.f7689;
                    AbstractC3520 abstractC35202 = this;
                    abstractC3520 = abstractC35202;
                    if (unsafe3.compareAndSwapObject(abstractC35202, f13524, (Object) null, c1735)) {
                        return;
                    }
                    if (unsafe3.getObjectVolatile(abstractC3520, j) != null) {
                        break;
                    } else {
                        this = abstractC3520;
                    }
                }
            } else {
                abstractC3520 = this;
                if (objectVolatile instanceof C3410) {
                    ((C3410) objectVolatile).m7810();
                    return;
                }
                if (objectVolatile == c1735) {
                    return;
                }
                C3410 c3410 = new C3410(8, true);
                c3410.m7812((Runnable) objectVolatile);
                do {
                    unsafe = AbstractC1929.f7689;
                    if (unsafe.compareAndSwapObject(abstractC3520, f13524, objectVolatile, c3410)) {
                        return;
                    }
                } while (unsafe.getObjectVolatile(abstractC3520, j) == objectVolatile);
            }
            this = abstractC3520;
        }
    }

    /* JADX INFO: renamed from: ᵽˀᵥ, reason: contains not printable characters */
    public final void m8034(long j, AbstractRunnableC2630 abstractRunnableC2630) {
        Thread threadMo8025;
        int iM8028 = m8028(j, abstractRunnableC2630);
        if (iM8028 == 0) {
            if (!m8027(abstractRunnableC2630) || Thread.currentThread() == (threadMo8025 = mo8025())) {
                return;
            }
            LockSupport.unpark(threadMo8025);
            return;
        }
        if (iM8028 == 1) {
            mo8020(j, abstractRunnableC2630);
        } else {
            if (iM8028 == 2) {
                return;
            }
            ᵕᵩʽᵲ.ᵪᵹᵥᵻ("unexpected result");
        }
    }
}