package e7;

import Z6.AbstractC0378s;
import Z6.B;
import Z6.C0369i;
import Z6.E;
import Z6.F;
import Z6.L;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: loaded from: classes.dex */
public final class g extends AbstractC0378s implements E {

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

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public final /* synthetic */ E f12551s;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final AbstractC0378s f12552t;

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

    /* JADX INFO: renamed from: v, reason: collision with root package name */
    public final k f12554v;

    /* JADX INFO: renamed from: w, reason: collision with root package name */
    public final Object f12555w;

    /* JADX WARN: Multi-variable type inference failed */
    public g(AbstractC0378s abstractC0378s, int i) {
        E e8 = abstractC0378s instanceof E ? (E) abstractC0378s : null;
        this.f12551s = e8 == null ? B.f7469a : e8;
        this.f12552t = abstractC0378s;
        this.f12553u = i;
        this.f12554v = new k();
        this.f12555w = new Object();
    }

    @Override // Z6.E
    public final void H(long j8, C0369i c0369i) {
        this.f12551s.H(j8, c0369i);
    }

    @Override // Z6.AbstractC0378s
    public final void j0(E6.i iVar, Runnable runnable) throws F {
        this.f12554v.a(runnable);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f12550x;
        if (atomicIntegerFieldUpdater.get(this) < this.f12553u) {
            synchronized (this.f12555w) {
                if (atomicIntegerFieldUpdater.get(this) >= this.f12553u) {
                    return;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
                Runnable runnableM0 = m0();
                if (runnableM0 == null) {
                    return;
                }
                AbstractC0892a.i(this.f12552t, this, new G3.b(this, runnableM0, 23, false));
            }
        }
    }

    @Override // Z6.AbstractC0378s
    public final AbstractC0378s l0(int i) {
        AbstractC0892a.a(1);
        return 1 >= this.f12553u ? this : super.l0(1);
    }

    public final Runnable m0() {
        while (true) {
            Runnable runnable = (Runnable) this.f12554v.d();
            if (runnable != null) {
                return runnable;
            }
            synchronized (this.f12555w) {
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f12550x;
                atomicIntegerFieldUpdater.decrementAndGet(this);
                if (this.f12554v.c() == 0) {
                    return null;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
            }
        }
    }

    @Override // Z6.AbstractC0378s
    public final String toString() {
        return this.f12552t + ".limitedParallelism(" + this.f12553u + ')';
    }

    @Override // Z6.E
    public final L u(long j8, Runnable runnable, E6.i iVar) {
        return this.f12551s.u(j8, runnable, iVar);
    }
}