package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* renamed from: ˊːˎʿ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C1315 extends AbstractC2687 implements InterfaceC5297 {

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f5414 = AtomicIntegerFieldUpdater.newUpdater(C1315.class, "runningWorkers$volatile");
    private volatile /* synthetic */ int runningWorkers$volatile;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public final Object f5415;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final /* synthetic */ InterfaceC5297 f5416;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final C1386 f5417;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final int f5418;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final AbstractC2687 f5419;

    /* JADX WARN: Multi-variable type inference failed */
    public C1315(AbstractC2687 abstractC2687, int i) {
        InterfaceC5297 interfaceC5297 = abstractC2687 instanceof InterfaceC5297 ? (InterfaceC5297) abstractC2687 : null;
        this.f5416 = interfaceC5297 == null ? AbstractC2451.f9569 : interfaceC5297;
        this.f5419 = abstractC2687;
        this.f5418 = i;
        this.f5417 = new C1386();
        this.f5415 = new Object();
    }

    @Override // defpackage.AbstractC2687
    public final String toString() {
        return this.f5419 + ".limitedParallelism(" + this.f5418 + ')';
    }

    @Override // defpackage.AbstractC2687
    /* renamed from: ʾᵻᵭٴ */
    public final void mo1226(InterfaceC2262 interfaceC2262, Runnable runnable) {
        Runnable runnableM4039;
        this.f5417.m4267(runnable);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f5414;
        if (atomicIntegerFieldUpdater.get(this) >= this.f5418 || !m4038() || (runnableM4039 = m4039()) == null) {
            return;
        }
        try {
            AbstractC1243.m3785(this.f5419, this, new ᵧˀ(15, this, runnableM4039, false));
        } catch (Throwable th) {
            atomicIntegerFieldUpdater.decrementAndGet(this);
            throw th;
        }
    }

    @Override // defpackage.InterfaceC5297
    /* renamed from: ˊᵸˊ, reason: contains not printable characters */
    public final void mo4037(long j, C4385 c4385) {
        this.f5416.mo4037(j, c4385);
    }

    @Override // defpackage.InterfaceC5297
    /* renamed from: ᵡⁱᵥ */
    public final InterfaceC3451 mo2062(long j, Runnable runnable, InterfaceC2262 interfaceC2262) {
        return this.f5416.mo2062(j, runnable, interfaceC2262);
    }

    /* renamed from: ᵣᵟᵔ, reason: contains not printable characters */
    public final boolean m4038() {
        synchronized (this.f5415) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f5414;
            if (atomicIntegerFieldUpdater.get(this) >= this.f5418) {
                return false;
            }
            atomicIntegerFieldUpdater.incrementAndGet(this);
            return true;
        }
    }

    @Override // defpackage.AbstractC2687
    /* renamed from: ᵺᵠ */
    public final void mo1228(InterfaceC2262 interfaceC2262, Runnable runnable) {
        Runnable runnableM4039;
        this.f5417.m4267(runnable);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f5414;
        if (atomicIntegerFieldUpdater.get(this) >= this.f5418 || !m4038() || (runnableM4039 = m4039()) == null) {
            return;
        }
        try {
            this.f5419.mo1228(this, new ᵧˀ(15, this, runnableM4039, false));
        } catch (Throwable th) {
            atomicIntegerFieldUpdater.decrementAndGet(this);
            throw th;
        }
    }

    /* renamed from: ﹶـ, reason: contains not printable characters */
    public final Runnable m4039() {
        while (true) {
            Runnable runnable = (Runnable) this.f5417.m4269();
            if (runnable != null) {
                return runnable;
            }
            synchronized (this.f5415) {
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f5414;
                atomicIntegerFieldUpdater.decrementAndGet(this);
                if (this.f5417.m4266() == 0) {
                    return null;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
            }
        }
    }
}