package h.a;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: compiled from: Builders.common.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public final class z<T> extends h.a.k1.q<T> {

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

    @Override // h.a.k1.q, h.a.a
    public void H(Object obj) {
        boolean z;
        while (true) {
            int i2 = this._decision;
            z = false;
            if (i2 != 0) {
                if (i2 != 1) {
                    throw new IllegalStateException("Already resumed".toString());
                }
            } else if (f4347e.compareAndSet(this, 0, 2)) {
                z = true;
                break;
            }
        }
        if (z) {
            return;
        }
        h.a.k1.e.a(f.a.y.a.m0(null), f.a.y.a.E0(obj, null), null, 2);
    }

    @Override // h.a.k1.q, h.a.v0
    public void j(Object obj) {
        H(obj);
    }
}