package defpackage;

import androidx.media3.exoplayer.upstream.CmcdData;
import defpackage.ca;
import java.util.Set;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.logging.Level;

/* JADX INFO: loaded from: classes2.dex */
@az3
@lw7
@ii2
abstract class dh<OutputT> extends ca.j<OutputT> {
    public static final b c;
    public static final y65 d = new y65(dh.class);
    public volatile Set a;
    public volatile int b;

    public static abstract class b {
        public abstract int a(zg zgVar);
    }

    public static final class c extends b {
        public final AtomicIntegerFieldUpdater a;

        public c(AtomicReferenceFieldUpdater atomicReferenceFieldUpdater, AtomicIntegerFieldUpdater atomicIntegerFieldUpdater) {
            this.a = atomicIntegerFieldUpdater;
        }

        @Override // dh.b
        public final int a(zg zgVar) {
            return this.a.decrementAndGet(zgVar);
        }
    }

    public static final class d extends b {
        @Override // dh.b
        public final int a(zg zgVar) {
            int i;
            synchronized (zgVar) {
                i = zgVar.b - 1;
                zgVar.b = i;
            }
            return i;
        }
    }

    static {
        Throwable th;
        b dVar;
        try {
            dVar = new c(AtomicReferenceFieldUpdater.newUpdater(dh.class, Set.class, CmcdData.OBJECT_TYPE_AUDIO_ONLY), AtomicIntegerFieldUpdater.newUpdater(dh.class, "b"));
            th = null;
        } catch (Throwable th2) {
            th = th2;
            dVar = new d();
        }
        c = dVar;
        if (th != null) {
            d.a().log(Level.SEVERE, "SafeAtomicHelper is broken!", th);
        }
    }
}