package fe;

import com.google.android.gms.internal.atv_ads_framework.d1;
import java.util.logging.Level;

/* JADX INFO: loaded from: classes3.dex */
public final class a implements Runnable {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final d1 f26046a = new d1(20);

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public volatile boolean f26048c;

    public a(d dVar) {
        this.f26047b = dVar;
    }

    @Override // java.lang.Runnable
    public final void run() {
        i iVarN;
        while (true) {
            try {
                try {
                    iVarN = this.f26046a.n();
                } catch (InterruptedException e10) {
                    this.f26047b.f26072p.d(Level.WARNING, Thread.currentThread().getName() + " was interruppted", e10);
                    this.f26048c = false;
                    return;
                }
                if (iVarN == null) {
                    synchronized (this) {
                        iVarN = this.f26046a.m();
                        if (iVarN == null) {
                            this.f26048c = false;
                            this.f26048c = false;
                            return;
                        }
                        this.f26047b.f26072p.d(Level.WARNING, Thread.currentThread().getName() + " was interruppted", e10);
                        this.f26048c = false;
                        return;
                    }
                }
                this.f26047b.c(iVarN);
            } catch (Throwable th) {
                this.f26048c = false;
                throw th;
            }
        }
    }
}