package d.a.s.g;

import d.a.m;
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;

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

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

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

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

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

    @Override // d.a.m.c
    public d.a.p.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        return this.f5876c ? d.a.s.a.c.INSTANCE : e(runnable, j2, timeUnit, null);
    }

    @Override // d.a.p.b
    public void dispose() {
        if (this.f5876c) {
            return;
        }
        this.f5876c = true;
        this.f5875b.shutdownNow();
    }

    public j e(Runnable runnable, long j2, TimeUnit timeUnit, d.a.s.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.f5875b.submit((Callable) jVar) : this.f5875b.schedule((Callable) jVar, j2, timeUnit));
        } catch (RejectedExecutionException e2) {
            if (aVar != null) {
                aVar.b(jVar);
            }
            d.a.u.a.w(e2);
        }
        return jVar;
    }

    @Override // d.a.p.b
    public boolean isDisposed() {
        return this.f5876c;
    }
}