package f.a.w.g;

import f.a.o;
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: compiled from: NewThreadWorker.java */
/* JADX INFO: loaded from: classes.dex */
public class h extends o.c implements f.a.t.b {

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

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

    public h(ThreadFactory threadFactory) {
        this.f4002b = m.a(threadFactory);
    }

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

    @Override // f.a.o.c
    public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        return this.f4003e ? f.a.w.a.c.INSTANCE : e(runnable, j2, timeUnit, null);
    }

    @Override // f.a.t.b
    public void dispose() {
        if (this.f4003e) {
            return;
        }
        this.f4003e = true;
        this.f4002b.shutdownNow();
    }

    public l e(Runnable runnable, long j2, TimeUnit timeUnit, f.a.w.a.a aVar) {
        Objects.requireNonNull(runnable, "run is null");
        l lVar = new l(runnable, aVar);
        if (aVar != null && !aVar.b(lVar)) {
            return lVar;
        }
        try {
            lVar.a(j2 <= 0 ? this.f4002b.submit((Callable) lVar) : this.f4002b.schedule((Callable) lVar, j2, timeUnit));
        } catch (RejectedExecutionException e2) {
            if (aVar != null) {
                aVar.a(lVar);
            }
            f.a.y.a.C0(e2);
        }
        return lVar;
    }
}