package kotlinx.coroutines.internal;

import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: compiled from: LockFreeTaskQueue.kt */
/* JADX INFO: loaded from: classes.dex */
public class p<E> {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private static final /* synthetic */ AtomicReferenceFieldUpdater f5224a = AtomicReferenceFieldUpdater.newUpdater(p.class, Object.class, "_cur");
    private volatile /* synthetic */ Object _cur;

    public p(boolean z2) {
        this._cur = new q(8, z2);
    }

    public final boolean a(E e3) {
        while (true) {
            q qVar = (q) this._cur;
            int iA = qVar.a(e3);
            if (iA == 0) {
                return true;
            }
            if (iA == 1) {
                f5224a.compareAndSet(this, qVar, qVar.i());
            } else if (iA == 2) {
                return false;
            }
        }
    }

    public final void b() {
        while (true) {
            q qVar = (q) this._cur;
            if (qVar.d()) {
                return;
            } else {
                f5224a.compareAndSet(this, qVar, qVar.i());
            }
        }
    }

    public final int c() {
        return ((q) this._cur).f();
    }

    public final E d() {
        while (true) {
            q qVar = (q) this._cur;
            E e3 = (E) qVar.j();
            if (e3 != q.f5228h) {
                return e3;
            }
            f5224a.compareAndSet(this, qVar, qVar.i());
        }
    }
}