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

import java.util.Iterator;
import java.util.PriorityQueue;
import java.util.concurrent.Executor;

/* JADX INFO: loaded from: classes2.dex */
public final class uk1 implements tk1 {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final PriorityQueue f17296b = new PriorityQueue();

    public uk1(Executor executor) {
        this.f17295a = executor;
    }

    @Override // com.google.android.gms.internal.ads.tk1
    public final void a(Runnable runnable, long j10) {
        if (j10 <= 0) {
            this.f17295a.execute(runnable);
            return;
        }
        vk1 vk1Var = new vk1(runnable, System.currentTimeMillis() + j10);
        PriorityQueue priorityQueue = this.f17296b;
        synchronized (priorityQueue) {
            priorityQueue.add(vk1Var);
        }
    }

    @Override // com.google.android.gms.internal.ads.tk1
    public final void zzb() {
        PriorityQueue priorityQueue = this.f17296b;
        synchronized (priorityQueue) {
            try {
                if (priorityQueue.isEmpty()) {
                    return;
                }
                PriorityQueue priorityQueue2 = new PriorityQueue();
                long jCurrentTimeMillis = System.currentTimeMillis();
                for (vk1 vk1Var = (vk1) priorityQueue.peek(); vk1Var != null && vk1Var.f17674b <= jCurrentTimeMillis; vk1Var = (vk1) priorityQueue.peek()) {
                    priorityQueue2.add(vk1Var);
                }
                Iterator it = priorityQueue2.iterator();
                while (it.hasNext()) {
                    try {
                        this.f17295a.execute(((vk1) it.next()).f17673a);
                    } catch (RuntimeException unused) {
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}