package p025.p026;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import p025.p026.p027.C1294;
import p138.p176.p177.p242.p246.p251.C4303;
import p402.p405.InterfaceC6575;
import p402.p405.InterfaceC6578;

/* JADX INFO: renamed from: އ.֏.ޠ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public final class C1338<T> extends C1294<T> {

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public static final AtomicIntegerFieldUpdater f4485 = AtomicIntegerFieldUpdater.newUpdater(C1338.class, "_decision");
    public volatile int _decision;

    public C1338(InterfaceC6578 interfaceC6578, InterfaceC6575<? super T> interfaceC6575) {
        super(interfaceC6578, interfaceC6575);
        this._decision = 0;
    }

    @Override // p025.p026.p027.C1294, p025.p026.C1368
    /* JADX INFO: renamed from: ؠ */
    public void mo2590(Object obj) {
        mo2591(obj);
    }

    @Override // p025.p026.p027.C1294, p025.p026.AbstractC1301
    /* JADX INFO: renamed from: ވ */
    public void mo2591(Object obj) {
        boolean z;
        while (true) {
            int i = this._decision;
            z = false;
            if (i != 0) {
                if (i != 1) {
                    throw new IllegalStateException("Already resumed".toString());
                }
            } else if (f4485.compareAndSet(this, 0, 2)) {
                z = true;
                break;
            }
        }
        if (z) {
            return;
        }
        C1337.m2663(C4303.m7066((InterfaceC6575) this.f4430), C4303.m7009(obj, (InterfaceC6575) this.f4430));
    }
}