package g.a;

/* JADX INFO: compiled from: CoroutineContext.kt */
/* JADX INFO: loaded from: classes.dex */
public final class k2<T> extends g.a.n2.z<T> {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private ThreadLocal<f.k<f.w.g, Object>> f4041h;

    public k2(f.w.g gVar, f.w.d<? super T> dVar) {
        super(gVar.get(l2.f4047b) == null ? gVar.plus(l2.f4047b) : gVar, dVar);
        this.f4041h = new ThreadLocal<>();
        if (dVar.getContext().get(f.w.e.f3959c) instanceof b0) {
            return;
        }
        Object objC = g.a.n2.f0.c(gVar, null);
        g.a.n2.f0.a(gVar, objC);
        x0(gVar, objC);
    }

    @Override // g.a.n2.z, g.a.a
    protected void s0(Object obj) {
        f.k<f.w.g, Object> kVar = this.f4041h.get();
        if (kVar != null) {
            g.a.n2.f0.a(kVar.a(), kVar.b());
            this.f4041h.set(null);
        }
        Object objA = x.a(obj, this.f4103g);
        f.w.d<T> dVar = this.f4103g;
        f.w.g context = dVar.getContext();
        Object objC = g.a.n2.f0.c(context, null);
        k2<?> k2VarG = objC != g.a.n2.f0.a ? a0.g(dVar, context, objC) : null;
        try {
            this.f4103g.resumeWith(objA);
            f.t tVar = f.t.a;
        } finally {
            if (k2VarG == null || k2VarG.w0()) {
                g.a.n2.f0.a(context, objC);
            }
        }
    }

    public final boolean w0() {
        if (this.f4041h.get() == null) {
            return false;
        }
        this.f4041h.set(null);
        return true;
    }

    public final void x0(f.w.g gVar, Object obj) {
        this.f4041h.set(f.p.a(gVar, obj));
    }
}