package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: renamed from: ᵳᵢ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4595 extends AbstractC2071 implements InterfaceC4129 {

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f17485 = AtomicIntegerFieldUpdater.newUpdater(C4595.class, "runningWorkers$volatile");
    private volatile /* synthetic */ int runningWorkers$volatile;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final AbstractC2071 f17486;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final /* synthetic */ InterfaceC4129 f17487;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public final int f17488;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final C2157 f17489;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public final Object f17490;

    /* JADX WARN: Multi-variable type inference failed */
    public C4595(AbstractC2071 abstractC2071, int i) {
        InterfaceC4129 interfaceC4129 = abstractC2071 instanceof InterfaceC4129 ? (InterfaceC4129) abstractC2071 : null;
        this.f17487 = interfaceC4129 == null ? AbstractC4340.f16524 : interfaceC4129;
        this.f17486 = abstractC2071;
        this.f17488 = i;
        this.f17489 = new C2157();
        this.f17490 = new Object();
    }

    @Override // defpackage.AbstractC2071
    public final String toString() {
        return this.f17486 + ".limitedParallelism(" + this.f17488 + ')';
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈᵲᵢ */
    public final InterfaceC0083 mo7668(long j, Runnable runnable, InterfaceC3822 interfaceC3822) {
        return this.f17487.mo7668(j, runnable, interfaceC3822);
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈⁱᵡ */
    public final void mo7669(long j, C3453 c3453) {
        this.f17487.mo7669(j, c3453);
    }

    @Override // defpackage.AbstractC2071
    /* JADX INFO: renamed from: ːᵝٴᵶ */
    public final void mo2300(InterfaceC3822 interfaceC3822, Runnable runnable) {
        Runnable runnableM9686;
        this.f17489.m5673(runnable);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f17485;
        if (atomicIntegerFieldUpdater.get(this) >= this.f17488 || !m9685() || (runnableM9686 = m9686()) == null) {
            return;
        }
        try {
            this.f17486.mo2300(this, new ᵙᵘ(15, this, runnableM9686, false));
        } catch (Throwable th) {
            atomicIntegerFieldUpdater.decrementAndGet(this);
            throw th;
        }
    }

    @Override // defpackage.AbstractC2071
    /* JADX INFO: renamed from: ᵜᵤ */
    public final void mo2301(InterfaceC3822 interfaceC3822, Runnable runnable) {
        Runnable runnableM9686;
        this.f17489.m5673(runnable);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f17485;
        if (atomicIntegerFieldUpdater.get(this) >= this.f17488 || !m9685() || (runnableM9686 = m9686()) == null) {
            return;
        }
        try {
            AbstractC5016.m10349(this.f17486, this, new ᵙᵘ(15, this, runnableM9686, false));
        } catch (Throwable th) {
            atomicIntegerFieldUpdater.decrementAndGet(this);
            throw th;
        }
    }

    /* JADX INFO: renamed from: ᵬᵦˋ, reason: contains not printable characters */
    public final boolean m9685() {
        synchronized (this.f17490) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f17485;
            if (atomicIntegerFieldUpdater.get(this) >= this.f17488) {
                return false;
            }
            atomicIntegerFieldUpdater.incrementAndGet(this);
            return true;
        }
    }

    /* JADX INFO: renamed from: ᵵᵸᵕᵸ, reason: contains not printable characters */
    public final Runnable m9686() {
        while (true) {
            Runnable runnable = (Runnable) this.f17489.m5674();
            if (runnable != null) {
                return runnable;
            }
            synchronized (this.f17490) {
                AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f17485;
                atomicIntegerFieldUpdater.decrementAndGet(this);
                if (this.f17489.m5672() == 0) {
                    return null;
                }
                atomicIntegerFieldUpdater.incrementAndGet(this);
            }
        }
    }
}