package f.a.n.g;

import f.a.g;
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 f extends g.c implements f.a.k.b {
    private final ScheduledExecutorService b;

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

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

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

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

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

    public j e(Runnable runnable, long j2, TimeUnit timeUnit, f.a.n.a.a aVar) {
        j jVar = new j(f.a.p.a.o(runnable), aVar);
        if (aVar != null && !aVar.c(jVar)) {
            return jVar;
        }
        try {
            jVar.a(j2 <= 0 ? this.b.submit((Callable) jVar) : this.b.schedule((Callable) jVar, j2, timeUnit));
        } catch (RejectedExecutionException e2) {
            if (aVar != null) {
                aVar.b(jVar);
            }
            f.a.p.a.m(e2);
        }
        return jVar;
    }

    public f.a.k.b f(Runnable runnable, long j2, TimeUnit timeUnit) {
        i iVar = new i(f.a.p.a.o(runnable));
        try {
            iVar.a(j2 <= 0 ? this.b.submit(iVar) : this.b.schedule(iVar, j2, timeUnit));
            return iVar;
        } catch (RejectedExecutionException e2) {
            f.a.p.a.m(e2);
            return f.a.n.a.c.INSTANCE;
        }
    }

    public f.a.k.b g(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        Runnable runnableO = f.a.p.a.o(runnable);
        if (j3 <= 0) {
            c cVar = new c(runnableO, this.b);
            try {
                cVar.b(j2 <= 0 ? this.b.submit(cVar) : this.b.schedule(cVar, j2, timeUnit));
                return cVar;
            } catch (RejectedExecutionException e2) {
                f.a.p.a.m(e2);
                return f.a.n.a.c.INSTANCE;
            }
        }
        h hVar = new h(runnableO);
        try {
            hVar.a(this.b.scheduleAtFixedRate(hVar, j2, j3, timeUnit));
            return hVar;
        } catch (RejectedExecutionException e3) {
            f.a.p.a.m(e3);
            return f.a.n.a.c.INSTANCE;
        }
    }

    public void h() {
        if (this.f904e) {
            return;
        }
        this.f904e = true;
        this.b.shutdown();
    }
}