package p138.p176.p291.p295;

import java.util.ArrayDeque;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executor;
import p138.p176.p291.p318.C5896;
import p138.p176.p291.p318.InterfaceC5897;
import p138.p176.p291.p318.InterfaceC5898;
import p138.p176.p291.p318.InterfaceC5899;

/* JADX INFO: renamed from: ދ.ހ.ށ.ރ.ސ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C5600 implements InterfaceC5899, InterfaceC5898 {

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final Map<Class<?>, ConcurrentHashMap<InterfaceC5897<Object>, Executor>> f16048 = new HashMap();

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public Queue<C5896<?>> f16049 = new ArrayDeque();

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public final Executor f16050;

    public C5600(Executor executor) {
        this.f16050 = executor;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final synchronized Set<Map.Entry<InterfaceC5897<Object>, Executor>> m8959(C5896<?> c5896) {
        ConcurrentHashMap<InterfaceC5897<Object>, Executor> concurrentHashMap;
        Map<Class<?>, ConcurrentHashMap<InterfaceC5897<Object>, Executor>> map = this.f16048;
        if (c5896 == null) {
            throw null;
        }
        concurrentHashMap = map.get(null);
        return concurrentHashMap == null ? Collections.emptySet() : concurrentHashMap.entrySet();
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m8960() {
        Queue<C5896<?>> queue;
        synchronized (this) {
            queue = null;
            if (this.f16049 != null) {
                Queue<C5896<?>> queue2 = this.f16049;
                this.f16049 = null;
                queue = queue2;
            }
        }
        if (queue != null) {
            Iterator<C5896<?>> it = queue.iterator();
            while (it.hasNext()) {
                m8963(it.next());
            }
        }
    }

    @Override // p138.p176.p291.p318.InterfaceC5899
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public synchronized <T> void mo8961(Class<T> cls, Executor executor, InterfaceC5897<? super T> interfaceC5897) {
        if (cls == null || interfaceC5897 == null || executor == null) {
            throw null;
        }
        if (!this.f16048.containsKey(cls)) {
            this.f16048.put(cls, new ConcurrentHashMap<>());
        }
        this.f16048.get(cls).put(interfaceC5897, executor);
    }

    @Override // p138.p176.p291.p318.InterfaceC5899
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public <T> void mo8962(Class<T> cls, InterfaceC5897<? super T> interfaceC5897) {
        mo8961(cls, this.f16050, interfaceC5897);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public void m8963(final C5896<?> c5896) {
        if (c5896 == null) {
            throw null;
        }
        synchronized (this) {
            if (this.f16049 != null) {
                this.f16049.add(c5896);
                return;
            }
            for (final Map.Entry<InterfaceC5897<Object>, Executor> entry : m8959(c5896)) {
                entry.getValue().execute(new Runnable(entry, c5896) { // from class: ދ.ހ.ށ.ރ.ޏ

                    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
                    public final Map.Entry f16046;

                    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
                    public final C5896 f16047;

                    {
                        this.f16046 = entry;
                        this.f16047 = c5896;
                    }

                    @Override // java.lang.Runnable
                    public void run() {
                        Map.Entry entry2 = this.f16046;
                        ((InterfaceC5897) entry2.getKey()).mo8942(this.f16047);
                    }
                });
            }
        }
    }
}