package J3;

import java.util.concurrent.Callable;
import java.util.concurrent.RunnableFuture;
import java.util.concurrent.locks.LockSupport;

/* JADX INFO: loaded from: classes3.dex */
public final class F extends p implements RunnableFuture, h {

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public volatile E f3506k;

    public F(Callable callable) {
        this.f3506k = new E(this, callable);
    }

    @Override // J3.p
    public final void b() {
        E e6;
        Object obj = this.f3536a;
        if ((obj instanceof C0435a) && ((C0435a) obj).f3509a && (e6 = this.f3506k) != null) {
            u uVar = E.f3503d;
            u uVar2 = E.f3502c;
            Runnable runnable = (Runnable) e6.get();
            if (runnable instanceof Thread) {
                t tVar = new t(e6);
                t.a(tVar, Thread.currentThread());
                if (e6.compareAndSet(runnable, tVar)) {
                    try {
                        ((Thread) runnable).interrupt();
                    } finally {
                        if (((Runnable) e6.getAndSet(uVar2)) == uVar) {
                            LockSupport.unpark((Thread) runnable);
                        }
                    }
                }
            }
        }
        this.f3506k = null;
    }

    @Override // J3.p
    public final String i() {
        E e6 = this.f3506k;
        if (e6 == null) {
            return super.i();
        }
        return "task=[" + e6 + "]";
    }

    @Override // J3.p, java.util.concurrent.Future
    public final boolean isCancelled() {
        return this.f3536a instanceof C0435a;
    }

    @Override // java.util.concurrent.RunnableFuture, java.lang.Runnable
    public final void run() {
        E e6 = this.f3506k;
        if (e6 != null) {
            e6.run();
        }
        this.f3506k = null;
    }
}