package c.a.q.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: compiled from: InstantPeriodicTask.java */
/* JADX INFO: loaded from: classes.dex */
final class c implements Callable<Void>, c.a.n.b {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    static final FutureTask<Void> f1839c = new FutureTask<>(c.a.q.b.a.f1739b, null);

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    final Runnable f1840d;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    final ExecutorService f1843g;
    Thread h;

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

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

    c(Runnable runnable, ExecutorService executorService) {
        this.f1840d = runnable;
        this.f1843g = executorService;
    }

    @Override // java.util.concurrent.Callable
    /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
    public Void call() throws Exception {
        try {
            this.h = Thread.currentThread();
            try {
                this.f1840d.run();
                c(this.f1843g.submit(this));
            } catch (Throwable th) {
                c.a.r.a.o(th);
            }
            return null;
        } finally {
            this.h = null;
        }
    }

    void b(Future<?> future) {
        Future<?> future2;
        do {
            future2 = this.f1842f.get();
            if (future2 == f1839c) {
                future.cancel(this.h != Thread.currentThread());
            }
        } while (!this.f1842f.compareAndSet(future2, future));
    }

    void c(Future<?> future) {
        Future<?> future2;
        do {
            future2 = this.f1841e.get();
            if (future2 == f1839c) {
                future.cancel(this.h != Thread.currentThread());
            }
        } while (!this.f1841e.compareAndSet(future2, future));
    }

    @Override // c.a.n.b
    public void dispose() {
        AtomicReference<Future<?>> atomicReference = this.f1842f;
        FutureTask<Void> futureTask = f1839c;
        Future<?> andSet = atomicReference.getAndSet(futureTask);
        if (andSet != null && andSet != futureTask) {
            andSet.cancel(this.h != Thread.currentThread());
        }
        Future<?> andSet2 = this.f1841e.getAndSet(futureTask);
        if (andSet2 == null || andSet2 == futureTask) {
            return;
        }
        andSet2.cancel(this.h != Thread.currentThread());
    }
}