package Z6;

import com.google.android.gms.internal.measurement.C1;
import e7.AbstractC0892a;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: loaded from: classes.dex */
public final class G extends e7.q {

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f7471u = AtomicIntegerFieldUpdater.newUpdater(G.class, "_decision$volatile");
    private volatile /* synthetic */ int _decision$volatile;

    @Override // e7.q, Z6.k0
    public final void p(Object obj) throws F {
        q(obj);
    }

    @Override // e7.q, Z6.k0
    public final void q(Object obj) throws F {
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater;
        do {
            atomicIntegerFieldUpdater = f7471u;
            int i = atomicIntegerFieldUpdater.get(this);
            if (i != 0) {
                if (i != 1) {
                    throw new IllegalStateException("Already resumed");
                }
                AbstractC0892a.h(C1.A(this.f12572t), AbstractC0385z.t(obj));
                return;
            }
        } while (!atomicIntegerFieldUpdater.compareAndSet(this, 0, 2));
    }
}