package e.a.u.f;

import e.a.u.c.d;
import e.a.u.h.g;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReferenceArray;

/* JADX INFO: compiled from: SpscArrayQueue.java */
/* JADX INFO: loaded from: classes.dex */
public final class a<E> extends AtomicReferenceArray<E> implements d<E> {

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private static final Integer f3776j = Integer.getInteger("jctools.spsc.max.lookahead.step", 4096);

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    final int f3777b;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    final AtomicLong f3778f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    long f3779g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    final AtomicLong f3780h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    final int f3781i;

    public a(int i2) {
        super(g.a(i2));
        this.f3777b = length() - 1;
        this.f3778f = new AtomicLong();
        this.f3780h = new AtomicLong();
        this.f3781i = Math.min(i2 / 4, f3776j.intValue());
    }

    int a(long j2) {
        return ((int) j2) & this.f3777b;
    }

    int b(long j2, int i2) {
        return ((int) j2) & i2;
    }

    E c(int i2) {
        return get(i2);
    }

    @Override // e.a.u.c.e
    public void clear() {
        while (true) {
            if (poll() == null && isEmpty()) {
                return;
            }
        }
    }

    void d(long j2) {
        this.f3780h.lazySet(j2);
    }

    void e(int i2, E e2) {
        lazySet(i2, e2);
    }

    void f(long j2) {
        this.f3778f.lazySet(j2);
    }

    @Override // e.a.u.c.e
    public boolean isEmpty() {
        return this.f3778f.get() == this.f3780h.get();
    }

    @Override // e.a.u.c.e
    public boolean offer(E e2) {
        if (e2 == null) {
            throw new NullPointerException("Null is not a valid element");
        }
        int i2 = this.f3777b;
        long j2 = this.f3778f.get();
        int iB = b(j2, i2);
        if (j2 >= this.f3779g) {
            long j3 = ((long) this.f3781i) + j2;
            if (c(b(j3, i2)) == null) {
                this.f3779g = j3;
            } else if (c(iB) != null) {
                return false;
            }
        }
        e(iB, e2);
        f(j2 + 1);
        return true;
    }

    @Override // e.a.u.c.d, e.a.u.c.e
    public E poll() {
        long j2 = this.f3780h.get();
        int iA = a(j2);
        E eC = c(iA);
        if (eC == null) {
            return null;
        }
        d(j2 + 1);
        e(iA, null);
        return eC;
    }
}