package d.f.a.i2;

import android.annotation.TargetApi;
import android.util.Log;
import f.a.o;
import f.a.w.g.d;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/* JADX INFO: compiled from: RxApiManager.java */
/* JADX INFO: loaded from: classes.dex */
public class b {
    public static b a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public o f2586b;

    @TargetApi(19)
    public b() {
        int iAvailableProcessors = Runtime.getRuntime().availableProcessors() + 1;
        Log.i("RxApiManager", "threadNum = " + iAvailableProcessors);
        ExecutorService executorServiceNewFixedThreadPool = Executors.newFixedThreadPool(iAvailableProcessors);
        o oVar = f.a.z.a.a;
        this.f2586b = new d(executorServiceNewFixedThreadPool, false);
    }

    public static b a() {
        if (a == null) {
            synchronized (b.class) {
                if (a == null) {
                    a = new b();
                }
            }
        }
        return a;
    }
}