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

import android.os.Handler;
import android.os.Looper;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes2.dex */
public final class ic {

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

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

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

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

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

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final ec[] f12475g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public ac f12476h;

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

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final ArrayList f12478j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final ru f12479k;

    public ic(vc vcVar, zv1 zv1Var) {
        ru ruVar = new ru(new Handler(Looper.getMainLooper()));
        this.f12469a = new AtomicInteger();
        this.f12470b = new HashSet();
        this.f12471c = new PriorityBlockingQueue();
        this.f12472d = new PriorityBlockingQueue();
        this.f12477i = new ArrayList();
        this.f12478j = new ArrayList();
        this.f12473e = vcVar;
        this.f12474f = zv1Var;
        this.f12475g = new ec[4];
        this.f12479k = ruVar;
    }

    public final void a() {
        ac acVar = this.f12476h;
        if (acVar != null) {
            acVar.f8622d = true;
            acVar.interrupt();
        }
        ec[] ecVarArr = this.f12475g;
        for (int i10 = 0; i10 < 4; i10++) {
            ec ecVar = ecVarArr[i10];
            if (ecVar != null) {
                ecVar.f10750d = true;
                ecVar.interrupt();
            }
        }
        PriorityBlockingQueue priorityBlockingQueue = this.f12471c;
        PriorityBlockingQueue priorityBlockingQueue2 = this.f12472d;
        zb zbVar = this.f12473e;
        ru ruVar = this.f12479k;
        ac acVar2 = new ac(priorityBlockingQueue, priorityBlockingQueue2, zbVar, ruVar);
        this.f12476h = acVar2;
        acVar2.start();
        for (int i11 = 0; i11 < 4; i11++) {
            ec ecVar2 = new ec(priorityBlockingQueue2, this.f12474f, zbVar, ruVar);
            ecVarArr[i11] = ecVar2;
            ecVar2.start();
        }
    }

    public final void b(gc gcVar) {
        gcVar.f11701g = this;
        HashSet hashSet = this.f12470b;
        synchronized (hashSet) {
            hashSet.add(gcVar);
        }
        gcVar.f11700f = Integer.valueOf(this.f12469a.incrementAndGet());
        gcVar.a("add-to-queue");
        c();
        this.f12471c.add(gcVar);
    }

    public final void c() {
        ArrayList arrayList = this.f12478j;
        synchronized (arrayList) {
            try {
                Iterator it = arrayList.iterator();
                if (it.hasNext()) {
                    com.google.android.gms.measurement.internal.u1.x(it.next());
                    throw null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}