package e.a.u.g;

import e.a.n;
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 e extends n.c implements e.a.r.b {

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    volatile boolean f3827f;

    public e(ThreadFactory threadFactory) {
        this.f3826b = j.a(threadFactory);
    }

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

    @Override // e.a.n.c
    public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        return this.f3827f ? e.a.u.a.c.INSTANCE : e(runnable, j2, timeUnit, null);
    }

    @Override // e.a.r.b
    public void dispose() {
        if (this.f3827f) {
            return;
        }
        this.f3827f = true;
        this.f3826b.shutdownNow();
    }

    public i e(Runnable runnable, long j2, TimeUnit timeUnit, e.a.u.a.a aVar) {
        i iVar = new i(e.a.w.a.s(runnable), aVar);
        if (aVar != null && !aVar.c(iVar)) {
            return iVar;
        }
        try {
            iVar.a(j2 <= 0 ? this.f3826b.submit((Callable) iVar) : this.f3826b.schedule((Callable) iVar, j2, timeUnit));
        } catch (RejectedExecutionException e2) {
            if (aVar != null) {
                aVar.b(iVar);
            }
            e.a.w.a.p(e2);
        }
        return iVar;
    }

    public e.a.r.b f(Runnable runnable, long j2, TimeUnit timeUnit) {
        h hVar = new h(e.a.w.a.s(runnable));
        try {
            hVar.a(j2 <= 0 ? this.f3826b.submit(hVar) : this.f3826b.schedule(hVar, j2, timeUnit));
            return hVar;
        } catch (RejectedExecutionException e2) {
            e.a.w.a.p(e2);
            return e.a.u.a.c.INSTANCE;
        }
    }

    public e.a.r.b g(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        g gVar = new g(e.a.w.a.s(runnable));
        try {
            gVar.a(this.f3826b.scheduleAtFixedRate(gVar, j2, j3, timeUnit));
            return gVar;
        } catch (RejectedExecutionException e2) {
            e.a.w.a.p(e2);
            return e.a.u.a.c.INSTANCE;
        }
    }

    public void h() {
        if (this.f3827f) {
            return;
        }
        this.f3827f = true;
        this.f3826b.shutdown();
    }

    @Override // e.a.r.b
    public boolean isDisposed() {
        return this.f3827f;
    }
}