package defpackage;

import j$.util.Objects;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicReference;

/* renamed from: ᵳᵪᵮ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class ExecutorC4595 extends AtomicReference implements Executor, Runnable {

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public static final /* synthetic */ int f17048 = 0;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public Executor f17049;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public ᵪᵨ f17050;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public Thread f17051;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public Runnable f17052;

    @Override // java.util.concurrent.Executor
    public final void execute(Runnable runnable) {
        if (get() == EnumC5493.f20596) {
            this.f17049 = null;
            this.f17050 = null;
            return;
        }
        this.f17051 = Thread.currentThread();
        try {
            ᵪᵨ r0 = this.f17050;
            Objects.requireNonNull(r0);
            ᵧˉʙ r02 = (ᵧˉʙ) r0.ᵿʗᵝʽ;
            if (((Thread) r02.ᵢˇᵭ) == this.f17051) {
                this.f17050 = null;
                ᵛᵾˏ.ᵿʗᵝʽ(((Runnable) r02.ᵿʗᵝʽ) == null);
                r02.ᵿʗᵝʽ = runnable;
                Executor executor = this.f17049;
                Objects.requireNonNull(executor);
                r02.ᵾᵬ = executor;
                this.f17049 = null;
            } else {
                Executor executor2 = this.f17049;
                Objects.requireNonNull(executor2);
                this.f17049 = null;
                this.f17052 = runnable;
                executor2.execute(this);
            }
            this.f17051 = null;
        } catch (Throwable th) {
            this.f17051 = null;
            throw th;
        }
    }

    @Override // java.lang.Runnable
    public final void run() {
        Executor executor;
        Thread threadCurrentThread = Thread.currentThread();
        if (threadCurrentThread != this.f17051) {
            Runnable runnable = this.f17052;
            Objects.requireNonNull(runnable);
            this.f17052 = null;
            runnable.run();
            return;
        }
        ᵧˉʙ r1 = new ᵧˉʙ(16, false);
        r1.ᵢˇᵭ = threadCurrentThread;
        ᵪᵨ r0 = this.f17050;
        Objects.requireNonNull(r0);
        r0.ᵿʗᵝʽ = r1;
        this.f17050 = null;
        try {
            Runnable runnable2 = this.f17052;
            Objects.requireNonNull(runnable2);
            this.f17052 = null;
            runnable2.run();
            while (true) {
                Runnable runnable3 = (Runnable) r1.ᵿʗᵝʽ;
                if (runnable3 == null || (executor = (Executor) r1.ᵾᵬ) == null) {
                    break;
                }
                r1.ᵿʗᵝʽ = null;
                r1.ᵾᵬ = null;
                executor.execute(runnable3);
            }
        } finally {
            r1.ᵢˇᵭ = null;
        }
    }
}