package d8;

import android.content.Context;
import android.util.Log;
import androidx.annotation.Nullable;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import w8.t;

/* JADX INFO: loaded from: classes2.dex */
public final class o {

    @Nullable
    private static o zza;

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public k f25043c = new k(this);

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public int f25044d = 1;

    public o(Context context, ScheduledExecutorService scheduledExecutorService) {
        this.f25042b = scheduledExecutorService;
        this.f25041a = context.getApplicationContext();
    }

    public static synchronized o a(Context context) {
        try {
            if (zza == null) {
                zza = new o(context, Executors.unconfigurableScheduledExecutorService(Executors.newScheduledThreadPool(1, new m.c("MessengerIpcClient", 2))));
            }
        } catch (Throwable th) {
            throw th;
        }
        return zza;
    }

    public final synchronized t b(m mVar) {
        try {
            if (Log.isLoggable("MessengerIpcClient", 3)) {
                "Queueing ".concat(mVar.toString());
            }
            if (!this.f25043c.b(mVar)) {
                k kVar = new k(this);
                this.f25043c = kVar;
                kVar.b(mVar);
            }
        } catch (Throwable th) {
            throw th;
        }
        return mVar.f25038b.f34224a;
    }
}