package p025.p026.p030;

import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import p025.p026.AbstractC1353;
import p025.p026.RunnableC1330;
import p402.p405.InterfaceC6578;

/* JADX INFO: renamed from: އ.֏.ၸ.ނ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public final class ExecutorC1427 extends AbstractC1353 implements InterfaceC1431, Executor {

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public static final AtomicIntegerFieldUpdater f4612 = AtomicIntegerFieldUpdater.newUpdater(ExecutorC1427.class, "inFlightTasks");

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public final C1425 f4614;

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public final int f4615;

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public final int f4616;

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public final ConcurrentLinkedQueue<Runnable> f4613 = new ConcurrentLinkedQueue<>();
    public volatile int inFlightTasks = 0;

    public ExecutorC1427(C1425 c1425, int i, int i2) {
        this.f4614 = c1425;
        this.f4615 = i;
        this.f4616 = i2;
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public void close() {
        throw new IllegalStateException("Close cannot be invoked on LimitingBlockingDispatcher".toString());
    }

    @Override // java.util.concurrent.Executor
    public void execute(Runnable runnable) {
        m2771(runnable, false);
    }

    @Override // p025.p026.AbstractC1323
    public String toString() {
        return super.toString() + "[dispatcher = " + this.f4614 + ']';
    }

    @Override // p025.p026.p030.InterfaceC1431
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void mo2770() {
        Runnable runnablePoll = this.f4613.poll();
        if (runnablePoll == null) {
            f4612.decrementAndGet(this);
            Runnable runnablePoll2 = this.f4613.poll();
            if (runnablePoll2 != null) {
                m2771(runnablePoll2, true);
                return;
            }
            return;
        }
        C1425 c1425 = this.f4614;
        if (c1425 == null) {
            throw null;
        }
        try {
            c1425.f4607.m2755(runnablePoll, (InterfaceC1431) this, true);
        } catch (RejectedExecutionException unused) {
            RunnableC1330.f4471.m2676(c1425.f4607.m2754(runnablePoll, this));
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m2771(Runnable runnable, boolean z) {
        while (f4612.incrementAndGet(this) > this.f4615) {
            this.f4613.add(runnable);
            if (f4612.decrementAndGet(this) >= this.f4615 || (runnable = this.f4613.poll()) == null) {
                return;
            }
        }
        C1425 c1425 = this.f4614;
        if (c1425 == null) {
            throw null;
        }
        try {
            c1425.f4607.m2755(runnable, this, z);
        } catch (RejectedExecutionException unused) {
            RunnableC1330.f4471.m2676(c1425.f4607.m2754(runnable, this));
        }
    }

    @Override // p025.p026.AbstractC1323
    /* JADX INFO: renamed from: ֏ */
    public void mo2643(InterfaceC6578 interfaceC6578, Runnable runnable) {
        m2771(runnable, false);
    }

    @Override // p025.p026.p030.InterfaceC1431
    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public int mo2772() {
        return this.f4616;
    }
}