package i.a.n.g;

import i.a.h;
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 h.c implements i.a.k.b {
    private final ScheduledExecutorService b;
    volatile boolean d;

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

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

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

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

    public j e(Runnable runnable, long j2, TimeUnit timeUnit, i.a.n.a.a aVar) {
        j jVar = new j(i.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 e) {
            if (aVar != null) {
                aVar.b(jVar);
            }
            i.a.p.a.l(e);
        }
        return jVar;
    }

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

    public i.a.k.b g(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        Runnable runnableO = i.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 e) {
                i.a.p.a.l(e);
                return i.a.n.a.c.INSTANCE;
            }
        }
        h hVar = new h(runnableO);
        try {
            hVar.a(this.b.scheduleAtFixedRate(hVar, j2, j3, timeUnit));
            return hVar;
        } catch (RejectedExecutionException e2) {
            i.a.p.a.l(e2);
            return i.a.n.a.c.INSTANCE;
        }
    }

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

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