package com.google.firebase.iid;

import android.content.Context;
import android.os.Bundle;
import android.util.Log;
import com.google.android.gms.common.util.concurrent.NamedThreadFactory;
import com.google.android.gms.tasks.Task;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;

/* loaded from: classes.dex */
public final class zzab {
    private static zzab e;
    private final Context a;
    private final ScheduledExecutorService b;
    private zzad c = new zzad(this);
    private int d = 1;

    private zzab(Context context, ScheduledExecutorService scheduledExecutorService) {
        this.b = scheduledExecutorService;
        this.a = context.getApplicationContext();
    }

    public static synchronized zzab a(Context context) {
        zzab zzabVar;
        synchronized (zzab.class) {
            if (e == null) {
                e = new zzab(context, Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("MessengerIpcClient")));
            }
            zzabVar = e;
        }
        return zzabVar;
    }

    public final Task<Bundle> a(int i, Bundle bundle) {
        return a(new zzam(a(), 1, bundle));
    }

    private final synchronized <T> Task<T> a(zzak<T> zzakVar) {
        if (Log.isLoggable("MessengerIpcClient", 3)) {
            String valueOf = String.valueOf(zzakVar);
            StringBuilder sb = new StringBuilder(String.valueOf(valueOf).length() + 9);
            sb.append("Queueing ");
            sb.append(valueOf);
            Log.d("MessengerIpcClient", sb.toString());
        }
        if (!this.c.a(zzakVar)) {
            this.c = new zzad(this);
            this.c.a(zzakVar);
        }
        return zzakVar.b.a();
    }

    private final synchronized int a() {
        int i;
        i = this.d;
        this.d = i + 1;
        return i;
    }
}