package d4;

import android.app.Activity;
import android.content.Context;
import androidx.window.extensions.core.util.function.Consumer;
import androidx.window.extensions.layout.WindowLayoutInfo;
import androidx.window.layout.l;
import androidx.window.layout.n;
import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.concurrent.locks.ReentrantLock;
import nb.g;

/* JADX INFO: loaded from: classes.dex */
public final class d implements p0.a, Consumer {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final ReentrantLock f24982b;

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final LinkedHashSet f24984d;

    public d(Activity activity) {
        g.i(activity, "context");
        this.f24981a = activity;
        this.f24982b = new ReentrantLock();
        this.f24984d = new LinkedHashSet();
    }

    @Override // p0.a
    /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
    public final void accept(WindowLayoutInfo windowLayoutInfo) {
        g.i(windowLayoutInfo, "value");
        ReentrantLock reentrantLock = this.f24982b;
        reentrantLock.lock();
        try {
            this.f24983c = c.b(this.f24981a, windowLayoutInfo);
            Iterator it = this.f24984d.iterator();
            while (it.hasNext()) {
                ((p0.a) it.next()).accept(this.f24983c);
            }
        } finally {
            reentrantLock.unlock();
        }
    }

    public final void b(l lVar) {
        ReentrantLock reentrantLock = this.f24982b;
        reentrantLock.lock();
        try {
            n nVar = this.f24983c;
            if (nVar != null) {
                lVar.accept(nVar);
            }
            this.f24984d.add(lVar);
            reentrantLock.unlock();
        } catch (Throwable th) {
            reentrantLock.unlock();
            throw th;
        }
    }

    public final boolean c() {
        return this.f24984d.isEmpty();
    }

    public final void d(p0.a aVar) {
        g.i(aVar, "listener");
        ReentrantLock reentrantLock = this.f24982b;
        reentrantLock.lock();
        try {
            this.f24984d.remove(aVar);
        } finally {
            reentrantLock.unlock();
        }
    }
}
