package c.a.q.f;

import c.a.q.c.c;
import c.a.q.h.d;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReferenceArray;

/* JADX INFO: compiled from: SpscLinkedArrayQueue.java */
/* JADX INFO: loaded from: classes.dex */
public final class a<T> implements c {

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private static final Object f1817d = new Object();

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    int f1819f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    long f1820g;
    final int h;
    AtomicReferenceArray<Object> i;
    final int j;
    AtomicReferenceArray<Object> k;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    final AtomicLong f1818e = new AtomicLong();
    final AtomicLong l = new AtomicLong();

    public a(int i) {
        int iA = d.a(Math.max(8, i));
        int i2 = iA - 1;
        AtomicReferenceArray<Object> atomicReferenceArray = new AtomicReferenceArray<>(iA + 1);
        this.i = atomicReferenceArray;
        this.h = i2;
        a(iA);
        this.k = atomicReferenceArray;
        this.j = i2;
        this.f1820g = i2 - 1;
        o(0L);
    }

    private void a(int i) {
        this.f1819f = Math.min(i / 4, f1816c);
    }

    private static int b(int i) {
        return i;
    }

    private static int c(long j, int i) {
        return b(((int) j) & i);
    }

    private long d() {
        return this.l.get();
    }

    private long e() {
        return this.f1818e.get();
    }

    private long f() {
        return this.l.get();
    }

    private static <E> Object g(AtomicReferenceArray<Object> atomicReferenceArray, int i) {
        return atomicReferenceArray.get(i);
    }

    private AtomicReferenceArray<Object> h(AtomicReferenceArray<Object> atomicReferenceArray) {
        return (AtomicReferenceArray) g(atomicReferenceArray, b(atomicReferenceArray.length() - 1));
    }

    private long i() {
        return this.f1818e.get();
    }

    private T j(AtomicReferenceArray<Object> atomicReferenceArray, long j, int i) {
        this.k = atomicReferenceArray;
        int iC = c(j, i);
        T t = (T) g(atomicReferenceArray, iC);
        if (t != null) {
            m(atomicReferenceArray, iC, null);
            l(j + 1);
        }
        return t;
    }

    private void k(AtomicReferenceArray<Object> atomicReferenceArray, long j, int i, T t, long j2) {
        AtomicReferenceArray<Object> atomicReferenceArray2 = new AtomicReferenceArray<>(atomicReferenceArray.length());
        this.i = atomicReferenceArray2;
        this.f1820g = (j2 + j) - 1;
        m(atomicReferenceArray2, i, t);
        n(atomicReferenceArray, atomicReferenceArray2);
        m(atomicReferenceArray, i, f1817d);
        o(j + 1);
    }

    private void l(long j) {
        this.l.lazySet(j);
    }

    private static void m(AtomicReferenceArray<Object> atomicReferenceArray, int i, Object obj) {
        atomicReferenceArray.lazySet(i, obj);
    }

    private void n(AtomicReferenceArray<Object> atomicReferenceArray, AtomicReferenceArray<Object> atomicReferenceArray2) {
        m(atomicReferenceArray, b(atomicReferenceArray.length() - 1), atomicReferenceArray2);
    }

    private void o(long j) {
        this.f1818e.lazySet(j);
    }

    private boolean p(AtomicReferenceArray<Object> atomicReferenceArray, T t, long j, int i) {
        m(atomicReferenceArray, i, t);
        o(j + 1);
        return true;
    }

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

    @Override // c.a.q.c.c
    public boolean isEmpty() {
        return i() == f();
    }

    @Override // c.a.q.c.c
    public boolean offer(T t) {
        Objects.requireNonNull(t, "Null is not a valid element");
        AtomicReferenceArray<Object> atomicReferenceArray = this.i;
        long jE = e();
        int i = this.h;
        int iC = c(jE, i);
        if (jE < this.f1820g) {
            return p(atomicReferenceArray, t, jE, iC);
        }
        long j = ((long) this.f1819f) + jE;
        if (g(atomicReferenceArray, c(j, i)) == null) {
            this.f1820g = j - 1;
            return p(atomicReferenceArray, t, jE, iC);
        }
        if (g(atomicReferenceArray, c(1 + jE, i)) == null) {
            return p(atomicReferenceArray, t, jE, iC);
        }
        k(atomicReferenceArray, jE, iC, t, i);
        return true;
    }

    @Override // c.a.q.c.c
    public T poll() {
        AtomicReferenceArray<Object> atomicReferenceArray = this.k;
        long jD = d();
        int i = this.j;
        int iC = c(jD, i);
        T t = (T) g(atomicReferenceArray, iC);
        boolean z = t == f1817d;
        if (t == null || z) {
            if (z) {
                return j(h(atomicReferenceArray), jD, i);
            }
            return null;
        }
        m(atomicReferenceArray, iC, null);
        l(jD + 1);
        return t;
    }
}