package D2;

import B2.i;
import B2.l;
import android.content.Context;
import androidx.window.extensions.layout.WindowLayoutInfo;
import androidx.window.reflection.Consumer2;
import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.concurrent.locks.ReentrantLock;
import kotlin.jvm.internal.o;

/* JADX INFO: loaded from: classes.dex */
public final class h implements E1.a, Consumer2 {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Context f950a;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public l f952c;

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final LinkedHashSet f953d = new LinkedHashSet();

    public h(Context context) {
        this.f950a = context;
    }

    public final void a(i iVar) {
        ReentrantLock reentrantLock = this.f951b;
        reentrantLock.lock();
        try {
            l lVar = this.f952c;
            if (lVar != null) {
                iVar.accept(lVar);
            }
            this.f953d.add(iVar);
            reentrantLock.unlock();
        } catch (Throwable th) {
            reentrantLock.unlock();
            throw th;
        }
    }

    @Override // E1.a
    public final void accept(Object obj) {
        WindowLayoutInfo value = (WindowLayoutInfo) obj;
        o.h(value, "value");
        ReentrantLock reentrantLock = this.f951b;
        reentrantLock.lock();
        try {
            l lVarC = g.c(this.f950a, value);
            this.f952c = lVarC;
            Iterator it = this.f953d.iterator();
            while (it.hasNext()) {
                ((E1.a) it.next()).accept(lVarC);
            }
        } finally {
            reentrantLock.unlock();
        }
    }
}