package androidx.window.java.core;

import java.util.LinkedHashMap;
import java.util.concurrent.Executor;
import java.util.concurrent.locks.ReentrantLock;
import kotlinx.coroutines.flow.f;
import kotlinx.coroutines.y;
import nb.g;

/* JADX INFO: loaded from: classes.dex */
public final class a {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final ReentrantLock f4441a = new ReentrantLock();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final LinkedHashMap f4442b = new LinkedHashMap();

    public final void a(Executor executor, p0.a aVar, f fVar) {
        g.i(fVar, "flow");
        ReentrantLock reentrantLock = this.f4441a;
        reentrantLock.lock();
        LinkedHashMap linkedHashMap = this.f4442b;
        try {
            if (linkedHashMap.get(aVar) == null) {
                linkedHashMap.put(aVar, hb.a.k0(y.b(y.o(executor)), null, new CallbackToFlowAdapter$connect$1$1(fVar, aVar, null), 3));
            }
        } finally {
            reentrantLock.unlock();
        }
    }
}