package defpackage;

import java.util.concurrent.Callable;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: renamed from: ːˊʢ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C1961 extends AbstractC4440 {

    /* JADX INFO: renamed from: ʿٴˇ, reason: contains not printable characters */
    public static final AtomicLong f7786 = new AtomicLong(Long.MIN_VALUE);

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public final C1799 f7787;

    /* JADX INFO: renamed from: ˌᵨʠᵫ, reason: contains not printable characters */
    public final C1799 f7788;

    /* JADX INFO: renamed from: ˑˊᵲ, reason: contains not printable characters */
    public final Semaphore f7789;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public C2696 f7790;

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public C2696 f7791;

    /* JADX INFO: renamed from: ᵯᵷʽ, reason: contains not printable characters */
    public final PriorityBlockingQueue f7792;

    /* JADX INFO: renamed from: ᵶˇᵱ, reason: contains not printable characters */
    public final LinkedBlockingQueue f7793;

    /* JADX INFO: renamed from: ᵸˆˁ, reason: contains not printable characters */
    public final Object f7794;

    public C1961(C1103 c1103) {
        super(c1103);
        this.f7794 = new Object();
        this.f7789 = new Semaphore(2);
        this.f7792 = new PriorityBlockingQueue();
        this.f7793 = new LinkedBlockingQueue();
        this.f7787 = new C1799(this, "Thread death: Uncaught exception on worker thread");
        this.f7788 = new C1799(this, "Thread death: Uncaught exception on network thread");
    }

    /* JADX INFO: renamed from: ʿٴˇ, reason: contains not printable characters */
    public final void m5240() {
        if (Thread.currentThread() == this.f7791) {
            return;
        }
        ᵕᵩʽᵲ.ᵪᵹᵥᵻ("Call expected from network thread");
    }

    /* JADX INFO: renamed from: ˀᵭ, reason: contains not printable characters */
    public final C4276 m5241(Callable callable) {
        m9448();
        C4276 c4276 = new C4276(this, callable, true);
        if (Thread.currentThread() == this.f7790) {
            c4276.run();
            return c4276;
        }
        m5248(c4276);
        return c4276;
    }

    /* JADX INFO: renamed from: ˁˌᵩ, reason: contains not printable characters */
    public final C4276 m5242(Callable callable) {
        m9448();
        C4276 c4276 = new C4276(this, callable, false);
        if (Thread.currentThread() != this.f7790) {
            m5248(c4276);
            return c4276;
        }
        if (!this.f7792.isEmpty()) {
            C3485 c3485 = ((C1103) ((ᵜᵪʾ) this).ˌᴵ).f4729;
            C1103.m3564(c3485);
            c3485.f13424.m4476("Callable skipped the worker queue.");
        }
        c4276.run();
        return c4276;
    }

    /* JADX INFO: renamed from: ˈᵲᵢ, reason: contains not printable characters */
    public final void m5243() {
        if (Thread.currentThread() == this.f7790) {
            return;
        }
        ᵕᵩʽᵲ.ᵪᵹᵥᵻ("Call expected from worker thread");
    }

    /* JADX INFO: renamed from: ˉᵵᵜ, reason: contains not printable characters */
    public final boolean m5244() {
        return Thread.currentThread() == this.f7790;
    }

    /* JADX INFO: renamed from: ˊᵡᵗʨ, reason: contains not printable characters */
    public final Object m5245(AtomicReference atomicReference, long j, String str, Runnable runnable) {
        synchronized (atomicReference) {
            C1961 c1961 = ((C1103) ((ᵜᵪʾ) this).ˌᴵ).f4707;
            C1103.m3564(c1961);
            c1961.m5246(runnable);
            try {
                atomicReference.wait(j);
            } catch (InterruptedException unused) {
                C3485 c3485 = ((C1103) ((ᵜᵪʾ) this).ˌᴵ).f4729;
                C1103.m3564(c3485);
                C1623 c1623 = c3485.f13424;
                StringBuilder sb = new StringBuilder(str.length() + 24);
                sb.append("Interrupted waiting for ");
                sb.append(str);
                c1623.m4476(sb.toString());
                return null;
            }
        }
        Object obj = atomicReference.get();
        if (obj == null) {
            C3485 c34852 = ((C1103) ((ᵜᵪʾ) this).ˌᴵ).f4729;
            C1103.m3564(c34852);
            c34852.f13424.m4476("Timed out waiting for ".concat(str));
        }
        return obj;
    }

    /* JADX INFO: renamed from: ˊᵾʽʼ, reason: contains not printable characters */
    public final void m5246(Runnable runnable) {
        m9448();
        ᵘᵞʿⁱ.ᵶᵥᵝ(runnable);
        m5248(new C4276(this, runnable, false, "Task exception on worker thread"));
    }

    @Override // defpackage.AbstractC4440
    /* JADX INFO: renamed from: ˌᵨʠᵫ, reason: contains not printable characters */
    public final boolean mo5247() {
        return false;
    }

    /* JADX INFO: renamed from: ˑʢ, reason: contains not printable characters */
    public final void m5248(C4276 c4276) {
        synchronized (this.f7794) {
            try {
                PriorityBlockingQueue priorityBlockingQueue = this.f7792;
                priorityBlockingQueue.add(c4276);
                C2696 c2696 = this.f7790;
                if (c2696 == null) {
                    C2696 c26962 = new C2696(this, "Measurement Worker", priorityBlockingQueue);
                    this.f7790 = c26962;
                    c26962.setUncaughtExceptionHandler(this.f7787);
                    this.f7790.start();
                } else {
                    c2696.m6507();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX INFO: renamed from: ᵛˑﹳ, reason: contains not printable characters */
    public final void m5249(Runnable runnable) {
        m9448();
        m5248(new C4276(this, runnable, true, "Task exception on worker thread"));
    }

    /* JADX INFO: renamed from: ᵠˏˏ, reason: contains not printable characters */
    public final void m5250() {
        if (Thread.currentThread() != this.f7790) {
            return;
        }
        ᵕᵩʽᵲ.ᵪᵹᵥᵻ("Call not expected from worker thread");
    }

    /* JADX INFO: renamed from: ᵵᵬᵽ, reason: contains not printable characters */
    public final void m5251(Runnable runnable) {
        m9448();
        C4276 c4276 = new C4276(this, runnable, false, "Task exception on network thread");
        synchronized (this.f7794) {
            try {
                LinkedBlockingQueue linkedBlockingQueue = this.f7793;
                linkedBlockingQueue.add(c4276);
                C2696 c2696 = this.f7791;
                if (c2696 == null) {
                    C2696 c26962 = new C2696(this, "Measurement Network", linkedBlockingQueue);
                    this.f7791 = c26962;
                    c26962.setUncaughtExceptionHandler(this.f7788);
                    this.f7791.start();
                } else {
                    c2696.m6507();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}