package m4;

import java.util.IdentityHashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes3.dex */
public final class f2 {

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static final f2 f21024d = new f2(new i2(15));

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final IdentityHashMap f21025a = new IdentityHashMap();

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

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

    public f2(i2 i2Var) {
        this.f21026b = i2Var;
    }

    public static Object a(e2 e2Var) {
        Object obj;
        f2 f2Var = f21024d;
        synchronized (f2Var) {
            try {
                d2 d2Var = (d2) f2Var.f21025a.get(e2Var);
                if (d2Var == null) {
                    d2Var = new d2(e2Var.b());
                    f2Var.f21025a.put(e2Var, d2Var);
                }
                ScheduledFuture scheduledFuture = d2Var.f20985c;
                if (scheduledFuture != null) {
                    scheduledFuture.cancel(false);
                    d2Var.f20985c = null;
                }
                d2Var.f20984b++;
                obj = d2Var.f20983a;
            } catch (Throwable th) {
                throw th;
            }
        }
        return obj;
    }

    public static void b(e2 e2Var, Object obj) {
        f2 f2Var = f21024d;
        synchronized (f2Var) {
            try {
                d2 d2Var = (d2) f2Var.f21025a.get(e2Var);
                if (d2Var == null) {
                    throw new IllegalArgumentException("No cached instance found for " + e2Var);
                }
                A4.g.l(obj == d2Var.f20983a, "Releasing the wrong instance");
                A4.g.t(d2Var.f20984b > 0, "Refcount has already reached zero");
                int i6 = d2Var.f20984b - 1;
                d2Var.f20984b = i6;
                if (i6 == 0) {
                    A4.g.t(d2Var.f20985c == null, "Destroy task already scheduled");
                    if (f2Var.f21027c == null) {
                        f2Var.f21026b.getClass();
                        f2Var.f21027c = Executors.newSingleThreadScheduledExecutor(AbstractC2504f0.e("grpc-shared-destroyer-%d"));
                    }
                    d2Var.f20985c = f2Var.f21027c.schedule(new B0(new F1.O(f2Var, d2Var, e2Var, obj, 4)), 1L, TimeUnit.SECONDS);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }
}