package c.f.j.p;

import android.util.Pair;
import java.util.Objects;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executor;
/* compiled from: ThrottlingProducer */
public class h1<T> implements v0<T> {
    public final v0<T> a;
    public int b = 0;

    /* renamed from: c  reason: collision with root package name */
    public final ConcurrentLinkedQueue<Pair<l<T>, w0>> f474c = new ConcurrentLinkedQueue<>();
    public final Executor d;

    /* compiled from: ThrottlingProducer */
    public class b extends p<T, T> {

        /* compiled from: ThrottlingProducer */
        public class a implements Runnable {
            public final /* synthetic */ Pair i;

            public a(Pair pair) {
                this.i = pair;
            }

            @Override // java.lang.Runnable
            public void run() {
                h1 h1Var = h1.this;
                Pair pair = this.i;
                w0 w0Var = (w0) pair.second;
                Objects.requireNonNull(h1Var);
                w0Var.o().j(w0Var, "ThrottlingProducer", null);
                h1Var.a.b(new b((l) pair.first, null), w0Var);
            }
        }

        public b(l lVar, a aVar) {
            super(lVar);
        }

        @Override // c.f.j.p.p, c.f.j.p.b
        public void g() {
            this.b.d();
            n();
        }

        @Override // c.f.j.p.p, c.f.j.p.b
        public void h(Throwable th) {
            this.b.c(th);
            n();
        }

        @Override // c.f.j.p.b
        public void i(T t, int i) {
            this.b.b(t, i);
            if (b.e(i)) {
                n();
            }
        }

        public final void n() {
            Pair<l<T>, w0> poll;
            synchronized (h1.this) {
                poll = h1.this.f474c.poll();
                if (poll == null) {
                    h1 h1Var = h1.this;
                    h1Var.b--;
                }
            }
            if (poll != null) {
                h1.this.d.execute(new a(poll));
            }
        }
    }

    public h1(int i, Executor executor, v0<T> v0Var) {
        Objects.requireNonNull(executor);
        this.d = executor;
        Objects.requireNonNull(v0Var);
        this.a = v0Var;
    }

    @Override // c.f.j.p.v0
    public void b(l<T> lVar, w0 w0Var) {
        boolean z2;
        w0Var.o().e(w0Var, "ThrottlingProducer");
        synchronized (this) {
            int i = this.b;
            z2 = true;
            if (i >= 5) {
                this.f474c.add(Pair.create(lVar, w0Var));
            } else {
                this.b = i + 1;
                z2 = false;
            }
        }
        if (!z2) {
            w0Var.o().j(w0Var, "ThrottlingProducer", null);
            this.a.b(new b(lVar, null), w0Var);
        }
    }
}