package defpackage;

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

/* JADX INFO: renamed from: ˆˁ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class ExecutorC0813 extends AtomicReference implements Executor, Runnable {

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public static final /* synthetic */ int f3647 = 0;

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public C0767 f3648;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public Runnable f3649;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public Executor f3650;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public Thread f3651;

    @Override // java.util.concurrent.Executor
    public final void execute(Runnable runnable) {
        if (get() == EnumC2279.f8977) {
            this.f3650 = null;
            this.f3648 = null;
            return;
        }
        this.f3651 = Thread.currentThread();
        try {
            C0767 c0767 = this.f3648;
            Objects.requireNonNull(c0767);
            ᵣˊˈᵪ r0 = (ᵣˊˈᵪ) c0767.f3432;
            if (((Thread) r0.ᵜᵪʾ) == this.f3651) {
                this.f3648 = null;
                ᵻᵪ.ˌᴵ(((Runnable) r0.ᵔᵖᵹᵫ) == null);
                r0.ᵔᵖᵹᵫ = runnable;
                Executor executor = this.f3650;
                Objects.requireNonNull(executor);
                r0.ᵨᵼⁱ = executor;
                this.f3650 = null;
            } else {
                Executor executor2 = this.f3650;
                Objects.requireNonNull(executor2);
                this.f3650 = null;
                this.f3649 = runnable;
                executor2.execute(this);
            }
            this.f3651 = null;
        } catch (Throwable th) {
            this.f3651 = null;
            throw th;
        }
    }

    @Override // java.lang.Runnable
    public final void run() {
        Executor executor;
        Thread threadCurrentThread = Thread.currentThread();
        if (threadCurrentThread != this.f3651) {
            Runnable runnable = this.f3649;
            Objects.requireNonNull(runnable);
            this.f3649 = null;
            runnable.run();
            return;
        }
        ᵣˊˈᵪ r1 = new ᵣˊˈᵪ(16, false);
        r1.ᵜᵪʾ = threadCurrentThread;
        C0767 c0767 = this.f3648;
        Objects.requireNonNull(c0767);
        c0767.f3432 = r1;
        this.f3648 = null;
        try {
            Runnable runnable2 = this.f3649;
            Objects.requireNonNull(runnable2);
            this.f3649 = 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;
        }
    }
}