package c.a.m.b;

import android.os.Handler;
import android.os.Message;
import c.a.g;
import c.a.n.c;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: HandlerScheduler.java */
/* JADX INFO: loaded from: classes.dex */
final class b extends g {

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

    /* JADX INFO: compiled from: HandlerScheduler.java */
    private static final class a extends g.c {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final Handler f1724c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        private volatile boolean f1725d;

        a(Handler handler) {
            this.f1724c = handler;
        }

        @Override // c.a.g.c
        public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
            Objects.requireNonNull(runnable, "run == null");
            Objects.requireNonNull(timeUnit, "unit == null");
            if (this.f1725d) {
                return c.a();
            }
            RunnableC0064b runnableC0064b = new RunnableC0064b(this.f1724c, c.a.r.a.q(runnable));
            Message messageObtain = Message.obtain(this.f1724c, runnableC0064b);
            messageObtain.obj = this;
            this.f1724c.sendMessageDelayed(messageObtain, Math.max(0L, timeUnit.toMillis(j)));
            if (!this.f1725d) {
                return runnableC0064b;
            }
            this.f1724c.removeCallbacks(runnableC0064b);
            return c.a();
        }

        @Override // c.a.n.b
        public void dispose() {
            this.f1725d = true;
            this.f1724c.removeCallbacksAndMessages(this);
        }
    }

    /* JADX INFO: renamed from: c.a.m.b.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: HandlerScheduler.java */
    private static final class RunnableC0064b implements Runnable, c.a.n.b {

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final Handler f1726c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        private final Runnable f1727d;

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

        RunnableC0064b(Handler handler, Runnable runnable) {
            this.f1726c = handler;
            this.f1727d = runnable;
        }

        @Override // c.a.n.b
        public void dispose() {
            this.f1728e = true;
            this.f1726c.removeCallbacks(this);
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                this.f1727d.run();
            } catch (Throwable th) {
                IllegalStateException illegalStateException = new IllegalStateException("Fatal Exception thrown on Scheduler.", th);
                c.a.r.a.o(illegalStateException);
                Thread threadCurrentThread = Thread.currentThread();
                threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, illegalStateException);
            }
        }
    }

    b(Handler handler) {
        this.f1723b = handler;
    }

    @Override // c.a.g
    public g.c a() {
        return new a(this.f1723b);
    }

    @Override // c.a.g
    public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
        Objects.requireNonNull(runnable, "run == null");
        Objects.requireNonNull(timeUnit, "unit == null");
        RunnableC0064b runnableC0064b = new RunnableC0064b(this.f1723b, c.a.r.a.q(runnable));
        this.f1723b.postDelayed(runnableC0064b, Math.max(0L, timeUnit.toMillis(j)));
        return runnableC0064b;
    }
}