package d.a.s.g;

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

/* JADX INFO: loaded from: classes.dex */
public final class c implements Callable<Void>, d.a.p.b {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final FutureTask<Void> f5833b = new FutureTask<>(d.a.s.b.a.f5671a, null);

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final ExecutorService f5837f;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final AtomicReference<Future<?>> f5836e = new AtomicReference<>();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicReference<Future<?>> f5835d = new AtomicReference<>();

    public c(Runnable runnable, ExecutorService executorService) {
        this.f5834c = runnable;
        this.f5837f = executorService;
    }

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

    @Override // java.util.concurrent.Callable
    public Void call() {
        this.f5838g = Thread.currentThread();
        try {
            this.f5834c.run();
            Future<?> futureSubmit = this.f5837f.submit(this);
            while (true) {
                Future<?> future = this.f5835d.get();
                if (future == f5833b) {
                    futureSubmit.cancel(this.f5838g != Thread.currentThread());
                } else if (this.f5835d.compareAndSet(future, futureSubmit)) {
                    break;
                }
            }
            this.f5838g = null;
        } catch (Throwable th) {
            this.f5838g = null;
            d.a.u.a.v(th);
        }
        return null;
    }

    @Override // d.a.p.b
    public void dispose() {
        AtomicReference<Future<?>> atomicReference = this.f5836e;
        FutureTask<Void> futureTask = f5833b;
        Future<?> andSet = atomicReference.getAndSet(futureTask);
        if (andSet != null && andSet != futureTask) {
            andSet.cancel(this.f5838g != Thread.currentThread());
        }
        Future<?> andSet2 = this.f5835d.getAndSet(futureTask);
        if (andSet2 == null || andSet2 == futureTask) {
            return;
        }
        andSet2.cancel(this.f5838g != Thread.currentThread());
    }

    @Override // d.a.p.b
    public boolean isDisposed() {
        return this.f5836e.get() == f5833b;
    }
}