package e.a.q.b;

import android.os.Handler;
import android.os.Message;
import e.a.n;
import e.a.r.c;
import java.util.concurrent.TimeUnit;

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

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

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

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

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

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

        @Override // e.a.n.c
        public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            if (runnable == null) {
                throw new NullPointerException("run == null");
            }
            if (timeUnit == null) {
                throw new NullPointerException("unit == null");
            }
            if (this.f3630f) {
                return c.a();
            }
            RunnableC0111b runnableC0111b = new RunnableC0111b(this.f3629b, e.a.w.a.s(runnable));
            Message messageObtain = Message.obtain(this.f3629b, runnableC0111b);
            messageObtain.obj = this;
            this.f3629b.sendMessageDelayed(messageObtain, Math.max(0L, timeUnit.toMillis(j2)));
            if (!this.f3630f) {
                return runnableC0111b;
            }
            this.f3629b.removeCallbacks(runnableC0111b);
            return c.a();
        }

        @Override // e.a.r.b
        public void dispose() {
            this.f3630f = true;
            this.f3629b.removeCallbacksAndMessages(this);
        }

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

    /* JADX INFO: renamed from: e.a.q.b.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: HandlerScheduler.java */
    private static final class RunnableC0111b implements Runnable, e.a.r.b {

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

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

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

        RunnableC0111b(Handler handler, Runnable runnable) {
            this.f3631b = handler;
            this.f3632f = runnable;
        }

        @Override // e.a.r.b
        public void dispose() {
            this.f3633g = true;
            this.f3631b.removeCallbacks(this);
        }

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

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

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

    @Override // e.a.n
    public n.c a() {
        return new a(this.f3628b);
    }

    @Override // e.a.n
    public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        if (runnable == null) {
            throw new NullPointerException("run == null");
        }
        if (timeUnit == null) {
            throw new NullPointerException("unit == null");
        }
        RunnableC0111b runnableC0111b = new RunnableC0111b(this.f3628b, e.a.w.a.s(runnable));
        this.f3628b.postDelayed(runnableC0111b, Math.max(0L, timeUnit.toMillis(j2)));
        return runnableC0111b;
    }
}