package defpackage;

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

/* renamed from: ᵺᵎᵹ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C5128 {

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final ArrayDeque f19096;

    /* renamed from: ˎˏʜʾ, reason: contains not printable characters */
    public final Object f19097;

    /* renamed from: ˏˋٴ, reason: contains not printable characters */
    public final ArrayDeque f19098;

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final InterfaceC0232 f19099;

    /* renamed from: ᵝᵵᵺ, reason: contains not printable characters */
    public final boolean f19100;

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final Thread f19101;

    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    public final C5073 f19102;

    /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */
    public boolean f19103;

    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final CopyOnWriteArraySet f19104;

    public C5128(Thread thread) {
        this(new CopyOnWriteArraySet(), null, thread, null, null, true);
    }

    public C5128(CopyOnWriteArraySet copyOnWriteArraySet, Looper looper, Thread thread, C1875 c1875, InterfaceC0232 interfaceC0232, boolean z) {
        this.f19101 = thread;
        this.f19104 = copyOnWriteArraySet;
        this.f19099 = interfaceC0232;
        this.f19097 = new Object();
        this.f19096 = new ArrayDeque();
        this.f19098 = new ArrayDeque();
        if (looper == null || c1875 == null || interfaceC0232 == null) {
            this.f19102 = null;
        } else {
            this.f19102 = c1875.m5287(looper, new C2810(0, this));
        }
        this.f19100 = z;
    }

    /* renamed from: ˇʼʤˎ, reason: contains not printable characters */
    public final void m10590(int i, InterfaceC2230 interfaceC2230) {
        m10591(i, interfaceC2230);
        m10593();
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final void m10591(int i, InterfaceC2230 interfaceC2230) {
        if (this.f19100) {
            ᵛᵾˏ.ᵿʗᵝʽ(Thread.currentThread() == this.f19101);
        }
        this.f19098.add(new ᵰˁ(new CopyOnWriteArraySet(this.f19104), i, interfaceC2230, 3));
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final void m10592(Object obj) {
        obj.getClass();
        synchronized (this.f19097) {
            try {
                if (this.f19103) {
                    return;
                }
                this.f19104.add(new C0400(obj));
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* renamed from: ᵴᵳ, reason: contains not printable characters */
    public final void m10593() {
        if (this.f19100) {
            ᵛᵾˏ.ᵿʗᵝʽ(Thread.currentThread() == this.f19101);
        }
        ArrayDeque arrayDeque = this.f19098;
        if (arrayDeque.isEmpty()) {
            return;
        }
        if (this.f19099 != null) {
            C5073 c5073 = this.f19102;
            c5073.getClass();
            Handler handler = c5073.f18953;
            if (!handler.hasMessages(1)) {
                C3363 c3363M10537 = c5073.m10537(1);
                Message message = c3363M10537.f12573;
                message.getClass();
                handler.sendMessageAtFrontOfQueue(message);
                c3363M10537.m7747();
            }
        }
        ArrayDeque arrayDeque2 = this.f19096;
        boolean zIsEmpty = arrayDeque2.isEmpty();
        arrayDeque2.addAll(arrayDeque);
        arrayDeque.clear();
        if (zIsEmpty) {
            while (!arrayDeque2.isEmpty()) {
                ((Runnable) arrayDeque2.peekFirst()).run();
                arrayDeque2.removeFirst();
            }
        }
    }

    /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */
    public final void m10594() {
        if (this.f19100) {
            ᵛᵾˏ.ᵿʗᵝʽ(Thread.currentThread() == this.f19101);
        }
        synchronized (this.f19097) {
            this.f19103 = true;
        }
        Iterator it = this.f19104.iterator();
        while (it.hasNext()) {
            C0400 c0400 = (C0400) it.next();
            InterfaceC0232 interfaceC0232 = this.f19099;
            c0400.f2281 = true;
            if (interfaceC0232 != null && c0400.f2278) {
                c0400.f2278 = false;
                interfaceC0232.mo1536(c0400.f2279, c0400.f2280.m9075());
            }
        }
        this.f19104.clear();
    }
}