package h.a.k1;

import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: compiled from: LockFreeTaskQueue.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public class j<E> {
    public static final /* synthetic */ AtomicReferenceFieldUpdater a = AtomicReferenceFieldUpdater.newUpdater(j.class, Object.class, "_cur");
    private volatile /* synthetic */ Object _cur;

    public j(boolean z) {
        this._cur = new k(8, z);
    }

    public final boolean a(E e2) {
        while (true) {
            k kVar = (k) this._cur;
            int iA = kVar.a(e2);
            if (iA == 0) {
                return true;
            }
            if (iA == 1) {
                a.compareAndSet(this, kVar, kVar.e());
            } else if (iA == 2) {
                return false;
            }
        }
    }

    public final void b() {
        while (true) {
            k kVar = (k) this._cur;
            if (kVar.b()) {
                return;
            } else {
                a.compareAndSet(this, kVar, kVar.e());
            }
        }
    }

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

    public final E d() {
        while (true) {
            k kVar = (k) this._cur;
            E e2 = (E) kVar.f();
            if (e2 != k.f4261d) {
                return e2;
            }
            a.compareAndSet(this, kVar, kVar.e());
        }
    }
}