package com.google.android.gms.internal.ads;

import androidx.annotation.Nullable;
import java.util.concurrent.Callable;
import java.util.concurrent.LinkedBlockingDeque;

/* JADX INFO: loaded from: classes2.dex */
public final class rb1 {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final LinkedBlockingDeque f16093a = new LinkedBlockingDeque();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Callable f16094b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final dv1 f16095c;

    public rb1(jp0 jp0Var, a30 a30Var) {
        this.f16094b = jp0Var;
        this.f16095c = a30Var;
    }

    public final synchronized void a(int i10) {
        LinkedBlockingDeque linkedBlockingDeque = this.f16093a;
        int size = i10 - linkedBlockingDeque.size();
        for (int i11 = 0; i11 < size; i11++) {
            linkedBlockingDeque.add(((iu1) this.f16095c).g(this.f16094b));
        }
    }

    @Nullable
    public final synchronized com.google.common.util.concurrent.w zzb() {
        a(1);
        return (com.google.common.util.concurrent.w) this.f16093a.poll();
    }
}