package o.a.h.g;

import java.util.Objects;
import java.util.concurrent.Callable;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import o.a.d;

/* JADX INFO: loaded from: classes.dex */
public class f extends d.c implements o.a.e.b {

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

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public volatile boolean f6072m;

    public f(ThreadFactory threadFactory) {
        this.f6071f = k.a(threadFactory);
    }

    @Override // o.a.e.b
    public void b() {
        if (this.f6072m) {
            return;
        }
        this.f6072m = true;
        this.f6071f.shutdownNow();
    }

    @Override // o.a.d.c
    public o.a.e.b c(Runnable runnable) {
        return d(runnable, 0L, null);
    }

    @Override // o.a.d.c
    public o.a.e.b d(Runnable runnable, long j2, TimeUnit timeUnit) {
        return this.f6072m ? o.a.h.a.c.INSTANCE : g(runnable, j2, timeUnit, null);
    }

    public j g(Runnable runnable, long j2, TimeUnit timeUnit, o.a.h.a.a aVar) {
        Objects.requireNonNull(runnable, "run is null");
        j jVar = new j(runnable, aVar);
        if (aVar != null && !aVar.c(jVar)) {
            return jVar;
        }
        try {
            jVar.a(j2 <= 0 ? this.f6071f.submit((Callable) jVar) : this.f6071f.schedule((Callable) jVar, j2, timeUnit));
        } catch (RejectedExecutionException e2) {
            if (aVar != null) {
                aVar.a(jVar);
            }
            g.h.a.i.P2(e2);
        }
        return jVar;
    }
}