package o.a.h.g;

import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public abstract class a extends AtomicReference<Future<?>> implements o.a.e.b {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final FutureTask<Void> f6027f;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public static final FutureTask<Void> f6028m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final Runnable f6029n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public Thread f6030o;

    static {
        Runnable runnable = o.a.h.b.a.a;
        f6027f = new FutureTask<>(runnable, null);
        f6028m = new FutureTask<>(runnable, null);
    }

    public a(Runnable runnable) {
        this.f6029n = runnable;
    }

    public final void a(Future<?> future) {
        Future<?> future2;
        do {
            future2 = get();
            if (future2 == f6027f) {
                return;
            }
            if (future2 == f6028m) {
                future.cancel(this.f6030o != Thread.currentThread());
                return;
            }
        } while (!compareAndSet(future2, future));
    }

    @Override // o.a.e.b
    public final void b() {
        FutureTask<Void> futureTask;
        Future<?> future = get();
        if (future == f6027f || future == (futureTask = f6028m) || !compareAndSet(future, futureTask) || future == null) {
            return;
        }
        future.cancel(this.f6030o != Thread.currentThread());
    }
}