package a5;

import V4.AbstractC0786y;
import V4.C0772m;
import V4.G;
import V4.I0;
import V4.J;
import V4.P;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: loaded from: classes3.dex */
public final class g extends AbstractC0786y implements J {

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f10826j = AtomicIntegerFieldUpdater.newUpdater(g.class, "runningWorkers$volatile");

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ J f10827b;

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final int f10829d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final j f10830e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final Object f10831f;
    private volatile /* synthetic */ int runningWorkers$volatile;

    /* JADX WARN: Multi-variable type inference failed */
    public g(AbstractC0786y abstractC0786y, int i6) {
        J j4 = abstractC0786y instanceof J ? (J) abstractC0786y : null;
        this.f10827b = j4 == null ? G.f8242a : j4;
        this.f10828c = abstractC0786y;
        this.f10829d = i6;
        this.f10830e = new j();
        this.f10831f = new Object();
    }

    @Override // V4.J
    public final void a(long j4, C0772m c0772m) {
        this.f10827b.a(j4, c0772m);
    }

    @Override // V4.J
    public final P b(long j4, I0 i02, A4.j jVar) {
        return this.f10827b.b(j4, i02, jVar);
    }

    @Override // V4.AbstractC0786y
    public final void c(A4.j jVar, Runnable runnable) {
        Runnable runnableT;
        this.f10830e.a(runnable);
        if (f10826j.get(this) >= this.f10829d || !y() || (runnableT = t()) == null) {
            return;
        }
        this.f10828c.c(this, new C1.a(11, this, false, runnableT));
    }

    @Override // V4.AbstractC0786y
    public final void f(A4.j jVar, Runnable runnable) {
        Runnable runnableT;
        this.f10830e.a(runnable);
        if (f10826j.get(this) >= this.f10829d || !y() || (runnableT = t()) == null) {
            return;
        }
        this.f10828c.f(this, new C1.a(11, this, false, runnableT));
    }

    @Override // V4.AbstractC0786y
    public final AbstractC0786y i(int i6) {
        AbstractC0988a.a(1);
        return 1 >= this.f10829d ? this : super.i(1);
    }

    public final Runnable t() {
        while (true) {
            Runnable runnable = (Runnable) this.f10830e.d();
            if (runnable != null) {
                return runnable;
            }
            synchronized (this.f10831f) {
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f10826j;
                atomicIntegerFieldUpdater.decrementAndGet(this);
                if (this.f10830e.c() == 0) {
                    return null;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
            }
        }
    }

    @Override // V4.AbstractC0786y
    public final String toString() {
        StringBuilder sb = new StringBuilder();
        sb.append(this.f10828c);
        sb.append(".limitedParallelism(");
        return com.google.android.recaptcha.internal.a.m(sb, this.f10829d, ')');
    }

    public final boolean y() {
        synchronized (this.f10831f) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f10826j;
            if (atomicIntegerFieldUpdater.get(this) >= this.f10829d) {
                return false;
            }
            atomicIntegerFieldUpdater.incrementAndGet(this);
            return true;
        }
    }
}