package com.google.android.gms.measurement.internal;

import androidx.annotation.Nullable;
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: loaded from: classes2.dex */
public final class j1 extends a2 {

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public static final AtomicLong f21670i = new AtomicLong(Long.MIN_VALUE);

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

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

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

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

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

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final Semaphore f21676h;

    @Nullable
    private n1 zzb;

    @Nullable
    private n1 zzc;

    public j1(m1 m1Var) {
        super(m1Var);
        this.f21675g = new Object();
        this.f21676h = new Semaphore(2);
        this.f21671c = new PriorityBlockingQueue();
        this.f21672d = new LinkedBlockingQueue();
        this.f21673e = new l1(this, "Thread death: Uncaught exception on worker thread");
        this.f21674f = new l1(this, "Thread death: Uncaught exception on network thread");
    }

    public final k1 A(Callable callable) {
        x();
        com.google.android.gms.common.internal.w.checkNotNull(callable);
        k1 k1Var = new k1(this, callable, false);
        if (Thread.currentThread() == this.zzb) {
            if (!this.f21671c.isEmpty()) {
                zzj().f21837i.c("Callable skipped the worker queue.");
            }
            k1Var.run();
        } else {
            D(k1Var);
        }
        return k1Var;
    }

    public final void D(k1 k1Var) {
        synchronized (this.f21675g) {
            try {
                this.f21671c.add(k1Var);
                n1 n1Var = this.zzb;
                if (n1Var == null) {
                    n1 n1Var2 = new n1(this, "Measurement Worker", this.f21671c);
                    this.zzb = n1Var2;
                    n1Var2.setUncaughtExceptionHandler(this.f21673e);
                    this.zzb.start();
                } else {
                    synchronized (n1Var.f21785a) {
                        n1Var.f21785a.notifyAll();
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final void E(Runnable runnable) {
        x();
        com.google.android.gms.common.internal.w.checkNotNull(runnable);
        k1 k1Var = new k1(this, runnable, false, "Task exception on network thread");
        synchronized (this.f21675g) {
            try {
                this.f21672d.add(k1Var);
                n1 n1Var = this.zzc;
                if (n1Var == null) {
                    n1 n1Var2 = new n1(this, "Measurement Network", this.f21672d);
                    this.zzc = n1Var2;
                    n1Var2.setUncaughtExceptionHandler(this.f21674f);
                    this.zzc.start();
                } else {
                    synchronized (n1Var.f21785a) {
                        n1Var.f21785a.notifyAll();
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final k1 F(Callable callable) {
        x();
        com.google.android.gms.common.internal.w.checkNotNull(callable);
        k1 k1Var = new k1(this, callable, true);
        if (Thread.currentThread() == this.zzb) {
            k1Var.run();
        } else {
            D(k1Var);
        }
        return k1Var;
    }

    public final void I(Runnable runnable) {
        x();
        com.google.android.gms.common.internal.w.checkNotNull(runnable);
        D(new k1(this, runnable, false, "Task exception on worker thread"));
    }

    public final void J(Runnable runnable) {
        x();
        com.google.android.gms.common.internal.w.checkNotNull(runnable);
        D(new k1(this, runnable, true, "Task exception on worker thread"));
    }

    public final boolean K() {
        return Thread.currentThread() == this.zzb;
    }

    public final void L() {
        if (Thread.currentThread() != this.zzc) {
            throw new IllegalStateException("Call expected from network thread");
        }
    }

    @Override // o0.i
    public final void w() {
        if (Thread.currentThread() != this.zzb) {
            throw new IllegalStateException("Call expected from worker thread");
        }
    }

    @Override // com.google.android.gms.measurement.internal.a2
    public final boolean z() {
        return false;
    }

    @Nullable
    public final <T> T zza(AtomicReference<T> atomicReference, long j10, String str, Runnable runnable) {
        synchronized (atomicReference) {
            zzl().I(runnable);
            try {
                atomicReference.wait(j10);
            } catch (InterruptedException unused) {
                zzj().f21837i.c("Interrupted waiting for " + str);
                return null;
            }
        }
        T t10 = atomicReference.get();
        if (t10 == null) {
            zzj().f21837i.c("Timed out waiting for " + str);
        }
        return t10;
    }
}