package s1;

import android.os.Process;
import java.lang.ref.ReferenceQueue;
import java.lang.ref.WeakReference;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import s1.p;

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

    /* renamed from: a, reason: collision with root package name */
    private final boolean f13769a;

    /* renamed from: b, reason: collision with root package name */
    private final Executor f13770b;

    /* renamed from: c, reason: collision with root package name */
    final Map f13771c;

    /* renamed from: d, reason: collision with root package name */
    private final ReferenceQueue f13772d;

    /* renamed from: e, reason: collision with root package name */
    private p.a f13773e;

    /* renamed from: f, reason: collision with root package name */
    private volatile boolean f13774f;

    /* renamed from: s1.a$a, reason: collision with other inner class name */
    class ThreadFactoryC0225a implements ThreadFactory {

        /* renamed from: s1.a$a$a, reason: collision with other inner class name */
        class RunnableC0226a implements Runnable {

            /* renamed from: a, reason: collision with root package name */
            final /* synthetic */ Runnable f13775a;

            RunnableC0226a(Runnable runnable) {
                this.f13775a = runnable;
            }

            @Override // java.lang.Runnable
            public void run() {
                Process.setThreadPriority(10);
                this.f13775a.run();
            }
        }

        ThreadFactoryC0225a() {
        }

        @Override // java.util.concurrent.ThreadFactory
        public Thread newThread(Runnable runnable) {
            return new Thread(new RunnableC0226a(runnable), "glide-active-resources");
        }
    }

    class b implements Runnable {
        b() {
        }

        @Override // java.lang.Runnable
        public void run() {
            a.this.b();
        }
    }

    static final class c extends WeakReference {

        /* renamed from: a, reason: collision with root package name */
        final q1.f f13778a;

        /* renamed from: b, reason: collision with root package name */
        final boolean f13779b;

        /* renamed from: c, reason: collision with root package name */
        v f13780c;

        c(q1.f fVar, p pVar, ReferenceQueue referenceQueue, boolean z10) {
            super(pVar, referenceQueue);
            this.f13778a = (q1.f) m2.j.d(fVar);
            this.f13780c = (pVar.f() && z10) ? (v) m2.j.d(pVar.e()) : null;
            this.f13779b = pVar.f();
        }

        void a() {
            this.f13780c = null;
            clear();
        }
    }

    a(boolean z10) {
        this(z10, Executors.newSingleThreadExecutor(new ThreadFactoryC0225a()));
    }

    synchronized void a(q1.f fVar, p pVar) {
        c cVar = (c) this.f13771c.put(fVar, new c(fVar, pVar, this.f13772d, this.f13769a));
        if (cVar != null) {
            cVar.a();
        }
    }

    void b() {
        while (!this.f13774f) {
            try {
                c((c) this.f13772d.remove());
            } catch (InterruptedException unused) {
                Thread.currentThread().interrupt();
            }
        }
    }

    void c(c cVar) {
        v vVar;
        synchronized (this) {
            this.f13771c.remove(cVar.f13778a);
            if (cVar.f13779b && (vVar = cVar.f13780c) != null) {
                this.f13773e.a(cVar.f13778a, new p(vVar, true, false, cVar.f13778a, this.f13773e));
            }
        }
    }

    synchronized void d(q1.f fVar) {
        c cVar = (c) this.f13771c.remove(fVar);
        if (cVar != null) {
            cVar.a();
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    synchronized p e(q1.f fVar) {
        c cVar = (c) this.f13771c.get(fVar);
        if (cVar == null) {
            return null;
        }
        p pVar = (p) cVar.get();
        if (pVar == null) {
            c(cVar);
        }
        return pVar;
    }

    void f(p.a aVar) {
        synchronized (aVar) {
            synchronized (this) {
                this.f13773e = aVar;
            }
        }
    }

    a(boolean z10, Executor executor) {
        this.f13771c = new HashMap();
        this.f13772d = new ReferenceQueue();
        this.f13769a = z10;
        this.f13770b = executor;
        executor.execute(new b());
    }
}