package kotlinx.coroutines.android;

import android.os.Handler;
import android.os.Looper;
import f.b0.n;
import f.t;
import f.w.g;
import f.z.d.k;
import f.z.d.l;
import g.a.j;
import g.a.r0;
import g.a.r1;
import g.a.x0;
import java.util.concurrent.CancellationException;

/* JADX INFO: compiled from: HandlerDispatcher.kt */
/* JADX INFO: loaded from: classes.dex */
public final class a extends kotlinx.coroutines.android.b implements r0 {
    private volatile a _immediate;

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final String f4433g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private final boolean f4434h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final a f4435i;

    /* JADX INFO: renamed from: kotlinx.coroutines.android.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: Runnable.kt */
    public static final class RunnableC0141a implements Runnable {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final /* synthetic */ j f4436b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final /* synthetic */ a f4437f;

        public RunnableC0141a(j jVar, a aVar) {
            this.f4436b = jVar;
            this.f4437f = aVar;
        }

        @Override // java.lang.Runnable
        public final void run() {
            this.f4436b.b(this.f4437f, t.a);
        }
    }

    /* JADX INFO: compiled from: HandlerDispatcher.kt */
    static final class b extends l implements f.z.c.l<Throwable, t> {

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

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        b(Runnable runnable) {
            super(1);
            this.f4439f = runnable;
        }

        public final void b(Throwable th) {
            a.this.f4432f.removeCallbacks(this.f4439f);
        }

        @Override // f.z.c.l
        public /* bridge */ /* synthetic */ t c(Throwable th) {
            b(th);
            return t.a;
        }
    }

    private a(Handler handler, String str, boolean z) {
        super(null);
        this.f4432f = handler;
        this.f4433g = str;
        this.f4434h = z;
        this._immediate = z ? this : null;
        a aVar = this._immediate;
        if (aVar == null) {
            aVar = new a(this.f4432f, this.f4433g, true);
            this._immediate = aVar;
        }
        this.f4435i = aVar;
    }

    private final void F(g gVar, Runnable runnable) {
        r1.c(gVar, new CancellationException("The task was rejected, the handler underlying the dispatcher '" + this + "' was closed"));
        x0.b().w(gVar, runnable);
    }

    @Override // g.a.y1
    /* JADX INFO: renamed from: H, reason: merged with bridge method [inline-methods] */
    public a B() {
        return this.f4435i;
    }

    public boolean equals(Object obj) {
        return (obj instanceof a) && ((a) obj).f4432f == this.f4432f;
    }

    @Override // g.a.r0
    public void h(long j2, j<? super t> jVar) {
        RunnableC0141a runnableC0141a = new RunnableC0141a(jVar, this);
        if (this.f4432f.postDelayed(runnableC0141a, n.d(j2, 4611686018427387903L))) {
            jVar.e(new b(runnableC0141a));
        } else {
            F(jVar.getContext(), runnableC0141a);
        }
    }

    public int hashCode() {
        return System.identityHashCode(this.f4432f);
    }

    @Override // g.a.y1, g.a.b0
    public String toString() {
        String strC = C();
        if (strC != null) {
            return strC;
        }
        String string = this.f4433g;
        if (string == null) {
            string = this.f4432f.toString();
        }
        if (!this.f4434h) {
            return string;
        }
        return string + ".immediate";
    }

    @Override // g.a.b0
    public void w(g gVar, Runnable runnable) {
        if (this.f4432f.post(runnable)) {
            return;
        }
        F(gVar, runnable);
    }

    @Override // g.a.b0
    public boolean x(g gVar) {
        return (this.f4434h && k.a(Looper.myLooper(), this.f4432f.getLooper())) ? false : true;
    }

    public /* synthetic */ a(Handler handler, String str, int i2, f.z.d.g gVar) {
        this(handler, (i2 & 2) != 0 ? null : str);
    }

    public a(Handler handler, String str) {
        this(handler, str, false);
    }
}