package f.a.s.b;

import android.annotation.SuppressLint;
import android.os.Handler;
import android.os.Message;
import f.a.o;
import f.a.w.a.c;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

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

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

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

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final boolean f3714e;

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

        public a(Handler handler, boolean z) {
            this.f3713b = handler;
            this.f3714e = z;
        }

        @Override // f.a.o.c
        @SuppressLint({"NewApi"})
        public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            Objects.requireNonNull(runnable, "run == null");
            Objects.requireNonNull(timeUnit, "unit == null");
            if (this.f3715f) {
                return c.INSTANCE;
            }
            Handler handler = this.f3713b;
            RunnableC0064b runnableC0064b = new RunnableC0064b(handler, runnable);
            Message messageObtain = Message.obtain(handler, runnableC0064b);
            messageObtain.obj = this;
            if (this.f3714e) {
                messageObtain.setAsynchronous(true);
            }
            this.f3713b.sendMessageDelayed(messageObtain, timeUnit.toMillis(j2));
            if (!this.f3715f) {
                return runnableC0064b;
            }
            this.f3713b.removeCallbacks(runnableC0064b);
            return c.INSTANCE;
        }

        @Override // f.a.t.b
        public void dispose() {
            this.f3715f = true;
            this.f3713b.removeCallbacksAndMessages(this);
        }
    }

    /* JADX INFO: renamed from: f.a.s.b.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: HandlerScheduler.java */
    public static final class RunnableC0064b implements Runnable, f.a.t.b {

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final Runnable f3717e;

        public RunnableC0064b(Handler handler, Runnable runnable) {
            this.f3716b = handler;
            this.f3717e = runnable;
        }

        @Override // f.a.t.b
        public void dispose() {
            this.f3716b.removeCallbacks(this);
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                this.f3717e.run();
            } catch (Throwable th) {
                f.a.y.a.C0(th);
            }
        }
    }

    public b(Handler handler, boolean z) {
        this.f3712b = handler;
    }

    @Override // f.a.o
    public o.c a() {
        return new a(this.f3712b, false);
    }

    @Override // f.a.o
    @SuppressLint({"NewApi"})
    public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        Objects.requireNonNull(runnable, "run == null");
        Objects.requireNonNull(timeUnit, "unit == null");
        Handler handler = this.f3712b;
        RunnableC0064b runnableC0064b = new RunnableC0064b(handler, runnable);
        this.f3712b.sendMessageDelayed(Message.obtain(handler, runnableC0064b), timeUnit.toMillis(j2));
        return runnableC0064b;
    }
}