package defpackage;

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

/* JADX INFO: renamed from: ᵢʢᵥˑ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C3252 {

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final C3086 f12366;

    /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */
    public boolean f12367;

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final InterfaceC1382 f12368;

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final ArrayDeque f12369;

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final Thread f12370;

    /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */
    public final Object f12371;

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public final CopyOnWriteArraySet f12372;

    /* JADX INFO: renamed from: ᵻʽᵯ, reason: contains not printable characters */
    public final boolean f12373;

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public final ArrayDeque f12374;

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

    public C3252(CopyOnWriteArraySet copyOnWriteArraySet, Looper looper, Thread thread, C2353 c2353, InterfaceC1382 interfaceC1382, boolean z) {
        this.f12370 = thread;
        this.f12372 = copyOnWriteArraySet;
        this.f12368 = interfaceC1382;
        this.f12371 = new Object();
        this.f12369 = new ArrayDeque();
        this.f12374 = new ArrayDeque();
        if (looper == null || c2353 == null || interfaceC1382 == null) {
            this.f12366 = null;
        } else {
            this.f12366 = c2353.m6030(looper, new C1875(0, this));
        }
        this.f12373 = z;
    }

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final void m7410() {
        if (this.f12373) {
            ᵻᵪ.ˌᴵ(Thread.currentThread() == this.f12370);
        }
        ArrayDeque arrayDeque = this.f12374;
        if (arrayDeque.isEmpty()) {
            return;
        }
        if (this.f12368 != null) {
            C3086 c3086 = this.f12366;
            c3086.getClass();
            Handler handler = c3086.f11775;
            if (!handler.hasMessages(1)) {
                C1150 c1150M7174 = c3086.m7174(1);
                Message message = c1150M7174.f4926;
                message.getClass();
                handler.sendMessageAtFrontOfQueue(message);
                c1150M7174.m3636();
            }
        }
        ArrayDeque arrayDeque2 = this.f12369;
        boolean zIsEmpty = arrayDeque2.isEmpty();
        arrayDeque2.addAll(arrayDeque);
        arrayDeque.clear();
        if (zIsEmpty) {
            while (!arrayDeque2.isEmpty()) {
                ((Runnable) arrayDeque2.peekFirst()).run();
                arrayDeque2.removeFirst();
            }
        }
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final void m7411(int i, InterfaceC1272 interfaceC1272) {
        if (this.f12373) {
            ᵻᵪ.ˌᴵ(Thread.currentThread() == this.f12370);
        }
        this.f12374.add(new ᵮʽᵩ(new CopyOnWriteArraySet(this.f12372), i, interfaceC1272, 3));
    }

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final void m7412(int i, InterfaceC1272 interfaceC1272) {
        m7411(i, interfaceC1272);
        m7410();
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final void m7413(Object obj) {
        obj.getClass();
        synchronized (this.f12371) {
            try {
                if (this.f12367) {
                    return;
                }
                this.f12372.add(new C1910(obj));
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public final void m7414() {
        if (this.f12373) {
            ᵻᵪ.ˌᴵ(Thread.currentThread() == this.f12370);
        }
        synchronized (this.f12371) {
            this.f12367 = true;
        }
        for (C1910 c1910 : this.f12372) {
            InterfaceC1382 interfaceC1382 = this.f12368;
            c1910.f7577 = true;
            if (interfaceC1382 != null && c1910.f7575) {
                c1910.f7575 = false;
                interfaceC1382.mo2610(c1910.f7576, c1910.f7574.m11189());
            }
        }
        this.f12372.clear();
    }
}