package androidx.window.layout.adapter.extensions;

import B2.i;
import B2.l;
import D2.g;
import E1.a;
import android.content.Context;
import androidx.window.extensions.layout.WindowLayoutInfo;
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 MulticastConsumer implements a {

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

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

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

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

    public MulticastConsumer(Context context) {
        this.f13196a = context;
    }

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

    @Override // E1.a
    public void accept(WindowLayoutInfo value) {
        o.h(value, "value");
        ReentrantLock reentrantLock = this.f13197b;
        reentrantLock.lock();
        try {
            l lVarC = g.c(this.f13196a, value);
            this.f13198c = lVarC;
            Iterator it = this.f13199d.iterator();
            while (it.hasNext()) {
                ((a) it.next()).accept(lVarC);
            }
        } finally {
            reentrantLock.unlock();
        }
    }
}