package l9;

import android.os.Handler;
import android.os.Looper;
import c9.l;
import d9.j;
import d9.k;
import g9.f;
import java.util.concurrent.CancellationException;
import k9.b1;
import k9.i2;
import k9.m;
import k9.y1;
import k9.z0;
import s8.v;
import v8.g;

/* loaded from: classes2.dex */
public final class b extends c {
    private volatile b _immediate;

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

    /* renamed from: c, reason: collision with root package name */
    private final String f11740c;

    /* renamed from: d, reason: collision with root package name */
    private final boolean f11741d;

    /* renamed from: e, reason: collision with root package name */
    private final b f11742e;

    public static final class a implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ m f11743a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ b f11744b;

        public a(m mVar, b bVar) {
            this.f11743a = mVar;
            this.f11744b = bVar;
        }

        @Override // java.lang.Runnable
        public final void run() {
            this.f11743a.g(this.f11744b, v.f14109a);
        }
    }

    /* renamed from: l9.b$b, reason: collision with other inner class name */
    static final class C0185b extends k implements l {

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ Runnable f11746b;

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

        public final void a(Throwable th) {
            b.this.f11739b.removeCallbacks(this.f11746b);
        }

        @Override // c9.l
        public /* bridge */ /* synthetic */ Object invoke(Object obj) {
            a((Throwable) obj);
            return v.f14109a;
        }
    }

    private b(Handler handler, String str, boolean z10) {
        super(null);
        this.f11739b = handler;
        this.f11740c = str;
        this.f11741d = z10;
        this._immediate = z10 ? this : null;
        b bVar = this._immediate;
        if (bVar == null) {
            bVar = new b(handler, str, true);
            this._immediate = bVar;
        }
        this.f11742e = bVar;
    }

    private final void L0(g gVar, Runnable runnable) {
        y1.c(gVar, new CancellationException("The task was rejected, the handler underlying the dispatcher '" + this + "' was closed"));
        z0.b().E0(gVar, runnable);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void N0(b bVar, Runnable runnable) {
        bVar.f11739b.removeCallbacks(runnable);
    }

    @Override // k9.g0
    public void E0(g gVar, Runnable runnable) {
        if (this.f11739b.post(runnable)) {
            return;
        }
        L0(gVar, runnable);
    }

    @Override // k9.g0
    public boolean F0(g gVar) {
        return (this.f11741d && j.a(Looper.myLooper(), this.f11739b.getLooper())) ? false : true;
    }

    @Override // k9.g2
    /* renamed from: M0, reason: merged with bridge method [inline-methods] */
    public b H0() {
        return this.f11742e;
    }

    @Override // k9.t0
    public void R(long j10, m mVar) {
        long d10;
        a aVar = new a(mVar, this);
        Handler handler = this.f11739b;
        d10 = f.d(j10, 4611686018427387903L);
        if (handler.postDelayed(aVar, d10)) {
            mVar.b(new C0185b(aVar));
        } else {
            L0(mVar.getContext(), aVar);
        }
    }

    @Override // k9.t0
    public b1 Y(long j10, final Runnable runnable, g gVar) {
        long d10;
        Handler handler = this.f11739b;
        d10 = f.d(j10, 4611686018427387903L);
        if (handler.postDelayed(runnable, d10)) {
            return new b1() { // from class: l9.a
                @Override // k9.b1
                public final void e() {
                    b.N0(b.this, runnable);
                }
            };
        }
        L0(gVar, runnable);
        return i2.f11356a;
    }

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

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

    @Override // k9.g0
    public String toString() {
        String I0 = I0();
        if (I0 != null) {
            return I0;
        }
        String str = this.f11740c;
        if (str == null) {
            str = this.f11739b.toString();
        }
        return this.f11741d ? j.l(str, ".immediate") : str;
    }

    public /* synthetic */ b(Handler handler, String str, int i10, d9.g gVar) {
        this(handler, (i10 & 2) != 0 ? null : str);
    }

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