package x0;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import java.util.ArrayDeque;
import java.util.concurrent.CopyOnWriteArraySet;
import u0.C1577m;

/* JADX INFO: loaded from: classes.dex */
public final class k {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final q f18518a;

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final i f18520c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final CopyOnWriteArraySet f18521d;

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final ArrayDeque f18523f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final Object f18524g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public boolean f18525h;
    public final boolean i;

    public k(Looper looper, q qVar, i iVar) {
        this(new CopyOnWriteArraySet(), looper, qVar, iVar, true);
    }

    public final void a(Object obj) {
        obj.getClass();
        synchronized (this.f18524g) {
            try {
                if (this.f18525h) {
                    return;
                }
                this.f18521d.add(new j(obj));
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final void b() {
        f();
        ArrayDeque arrayDeque = this.f18523f;
        if (arrayDeque.isEmpty()) {
            return;
        }
        s sVar = this.f18519b;
        if (!sVar.f18548a.hasMessages(1)) {
            sVar.getClass();
            r rVarB = s.b();
            rVarB.f18546a = sVar.f18548a.obtainMessage(1);
            sVar.getClass();
            Message message = rVarB.f18546a;
            message.getClass();
            sVar.f18548a.sendMessageAtFrontOfQueue(message);
            rVarB.a();
        }
        ArrayDeque arrayDeque2 = this.f18522e;
        boolean zIsEmpty = arrayDeque2.isEmpty();
        arrayDeque2.addAll(arrayDeque);
        arrayDeque.clear();
        if (zIsEmpty) {
            while (!arrayDeque2.isEmpty()) {
                ((Runnable) arrayDeque2.peekFirst()).run();
                arrayDeque2.removeFirst();
            }
        }
    }

    public final void c(int i, h hVar) {
        f();
        this.f18523f.add(new L1.a(i, 1, new CopyOnWriteArraySet(this.f18521d), hVar));
    }

    public final void d() {
        f();
        synchronized (this.f18524g) {
            this.f18525h = true;
        }
        for (j jVar : this.f18521d) {
            i iVar = this.f18520c;
            jVar.f18517d = true;
            if (jVar.f18516c) {
                jVar.f18516c = false;
                iVar.c(jVar.f18514a, jVar.f18515b.c());
            }
        }
        this.f18521d.clear();
    }

    public final void e(int i, h hVar) {
        c(i, hVar);
        b();
    }

    public final void f() {
        if (this.i) {
            AbstractC1709a.j(Thread.currentThread() == this.f18519b.f18548a.getLooper().getThread());
        }
    }

    public k(CopyOnWriteArraySet copyOnWriteArraySet, Looper looper, q qVar, i iVar, boolean z8) {
        this.f18518a = qVar;
        this.f18521d = copyOnWriteArraySet;
        this.f18520c = iVar;
        this.f18524g = new Object();
        this.f18522e = new ArrayDeque();
        this.f18523f = new ArrayDeque();
        this.f18519b = qVar.a(looper, new Handler.Callback() { // from class: x0.g
            @Override // android.os.Handler.Callback
            public final boolean handleMessage(Message message) {
                k kVar = this.f18513q;
                for (j jVar : kVar.f18521d) {
                    if (!jVar.f18517d && jVar.f18516c) {
                        C1577m c1577mC = jVar.f18515b.c();
                        jVar.f18515b = new K.g();
                        jVar.f18516c = false;
                        kVar.f18520c.c(jVar.f18514a, c1577mC);
                    }
                    if (kVar.f18519b.f18548a.hasMessages(1)) {
                        break;
                    }
                }
                return true;
            }
        });
        this.i = z8;
    }
}