package com.bytedance.sdk.openadsdk.utils;

import android.os.Looper;
import android.text.TextUtils;
import com.bytedance.sdk.component.qsH.tN.vc;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.json.JSONObject;
/* loaded from: classes2.dex */
public class mn {
    private static volatile com.bytedance.sdk.component.qsH.tN.vc AlY;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc DSW;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc NjR;
    private static volatile boolean Sg;
    private static volatile ThreadPoolExecutor YFl;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc eT;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc nc;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc qsH;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc tN;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc vc;
    private static volatile com.bytedance.sdk.component.qsH.tN.vc wN;

    static {
        com.bytedance.sdk.component.qsH.tN.tN.YFl(new com.bytedance.sdk.component.qsH.tN.YFl() { // from class: com.bytedance.sdk.openadsdk.utils.mn.1
            @Override // com.bytedance.sdk.component.qsH.tN.YFl
            public void YFl(com.bytedance.sdk.component.qsH.tN.vc vcVar, com.bytedance.sdk.component.qsH.tN.Sg sg) {
                sg.Sg();
                new RuntimeException();
            }
        });
        com.bytedance.sdk.component.qsH.tN.tN.YFl(new com.bytedance.sdk.component.qsH.tN.wN() { // from class: com.bytedance.sdk.openadsdk.utils.mn.3
            @Override // com.bytedance.sdk.component.qsH.tN.wN
            public void YFl(final com.bytedance.sdk.component.qsH.tN.vc vcVar) {
                if (Cfr.YFl || vcVar == null) {
                    return;
                }
                try {
                    LinkedHashMap<String, com.bytedance.sdk.component.qsH.tN.YFl.YFl> YFl2 = vcVar.YFl();
                    if (YFl2 == null || YFl2.size() <= 0) {
                        return;
                    }
                    for (Map.Entry<String, com.bytedance.sdk.component.qsH.tN.YFl.YFl> entry : YFl2.entrySet()) {
                        final com.bytedance.sdk.component.qsH.tN.YFl.YFl value = entry.getValue();
                        if (value != null) {
                            com.bytedance.sdk.openadsdk.pDU.tN.YFl();
                            com.bytedance.sdk.openadsdk.pDU.tN.YFl("pag_thread_pool_state", false, new com.bytedance.sdk.openadsdk.pDU.Sg() { // from class: com.bytedance.sdk.openadsdk.utils.mn.3.1
                                @Override // com.bytedance.sdk.openadsdk.pDU.Sg
                                public com.bytedance.sdk.openadsdk.pDU.YFl.tN getLogStats() throws Exception {
                                    JSONObject jSONObject = new JSONObject();
                                    try {
                                        jSONObject.put("name", value.YFl());
                                        jSONObject.put("times", value.Sg());
                                        jSONObject.put("runMaxTime", value.vc());
                                        jSONObject.put("waitMaxTime", value.wN());
                                        long Sg2 = value.Sg() == 0 ? 1 : value.Sg();
                                        jSONObject.put("avgRunTime", value.AlY() / Sg2);
                                        jSONObject.put("avgWaitTime", value.tN() / Sg2);
                                        jSONObject.put("poolType", vcVar.Sg());
                                    } catch (Exception e) {
                                        com.bytedance.sdk.component.utils.YoT.YFl("ThreadUtils", "run: ", e);
                                    }
                                    return com.bytedance.sdk.openadsdk.pDU.YFl.AlY.Sg().YFl("pag_thread_pool_state").Sg(jSONObject.toString());
                                }
                            });
                        }
                    }
                } catch (Throwable th) {
                    th.getMessage();
                }
            }
        });
        YFl = null;
        Sg = false;
    }

    public static ScheduledExecutorService YFl() {
        return com.bytedance.sdk.component.qsH.vc.vc();
    }

    public static ExecutorService Sg() {
        if (eT()) {
            return lG();
        }
        return com.bytedance.sdk.component.qsH.vc.nc();
    }

    public static ExecutorService tN() {
        if (eT()) {
            return EH();
        }
        return com.bytedance.sdk.component.qsH.vc.AlY();
    }

    public static ExecutorService AlY() {
        if (eT()) {
            return pDU();
        }
        return com.bytedance.sdk.component.qsH.vc.Sg();
    }

    public static boolean wN() {
        return Looper.getMainLooper() == Looper.myLooper();
    }

    public static boolean vc() {
        String str = eT() ? "pag_log" : "csj_log";
        String name = Thread.currentThread().getName();
        if (TextUtils.isEmpty(name)) {
            return false;
        }
        return name.startsWith(str);
    }

    public static void YFl(Runnable runnable) {
        if (runnable == null || Cfr.YFl) {
            return;
        }
        if (wN()) {
            runnable.run();
        } else {
            com.bytedance.sdk.openadsdk.core.pDU.tN().post(runnable);
        }
    }

    public static void Sg(Runnable runnable) {
        if (runnable == null) {
            return;
        }
        com.bytedance.sdk.openadsdk.core.pDU.tN().removeCallbacks(runnable);
    }

    public static void YFl(final com.bytedance.sdk.component.qsH.qsH qsh) {
        if (Cfr.YFl) {
            return;
        }
        if (eT()) {
            pDU().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.4
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
        } else {
            com.bytedance.sdk.component.qsH.vc.YFl(qsh);
        }
    }

    public static ExecutorService DSW() {
        if (eT()) {
            return Wwa();
        }
        return com.bytedance.sdk.component.qsH.vc.tN();
    }

    public static void Sg(final com.bytedance.sdk.component.qsH.qsH qsh) {
        if (Cfr.YFl) {
            return;
        }
        if (eT()) {
            Wwa().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.5
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
        } else {
            com.bytedance.sdk.component.qsH.vc.Sg(qsh);
        }
    }

    public static void YFl(final com.bytedance.sdk.component.qsH.qsH qsh, int i) {
        if (qsh == null || Cfr.YFl) {
            return;
        }
        if (eT()) {
            com.bytedance.sdk.component.qsH.tN.Sg sg = new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.6
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            };
            sg.YFl(i);
            Wwa().execute(sg);
            return;
        }
        com.bytedance.sdk.component.qsH.vc.YFl(qsh, 5, i);
    }

    public static void tN(final com.bytedance.sdk.component.qsH.qsH qsh) {
        if (qsh == null || Cfr.YFl) {
            return;
        }
        if (eT()) {
            EH().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.7
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
        } else {
            com.bytedance.sdk.component.qsH.vc.tN(qsh);
        }
    }

    public static void Sg(final com.bytedance.sdk.component.qsH.qsH qsh, int i) {
        if (qsh == null || Cfr.YFl) {
            return;
        }
        if (eT()) {
            com.bytedance.sdk.component.qsH.tN.Sg sg = new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.8
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            };
            sg.YFl(i);
            EH().execute(sg);
            return;
        }
        com.bytedance.sdk.component.qsH.vc.Sg(qsh, i);
    }

    public static void AlY(final com.bytedance.sdk.component.qsH.qsH qsh) {
        if (qsh == null || Cfr.YFl) {
            return;
        }
        if (eT()) {
            GA().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.9
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
        } else {
            com.bytedance.sdk.component.qsH.vc.wN(qsh);
        }
    }

    public static void tN(final com.bytedance.sdk.component.qsH.qsH qsh, int i) {
        if (qsh == null || Cfr.YFl) {
            return;
        }
        if (eT()) {
            rkt().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName()) { // from class: com.bytedance.sdk.openadsdk.utils.mn.10
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
        } else {
            com.bytedance.sdk.component.qsH.vc.tN(qsh, i);
        }
    }

    public static void wN(final com.bytedance.sdk.component.qsH.qsH qsh) {
        if (Cfr.YFl) {
            return;
        }
        if (eT()) {
            GA().execute(new com.bytedance.sdk.component.qsH.tN.Sg(qsh.getName(), qsh) { // from class: com.bytedance.sdk.openadsdk.utils.mn.2
                @Override // java.lang.Runnable
                public void run() {
                    qsh.run();
                }
            });
            return;
        }
        ThreadPoolExecutor YoT = YoT();
        YoT.execute(qsh);
        if (Sg || !com.bytedance.sdk.openadsdk.core.settings.rkt.HVP()) {
            return;
        }
        Sg = true;
        YoT.setCorePoolSize(com.bytedance.sdk.openadsdk.core.settings.rkt.JwO().rE());
    }

    public static void YFl(com.bytedance.sdk.component.qsH.tN.Sg sg) {
        nc().execute(sg);
    }

    private static ThreadPoolExecutor YoT() {
        int i;
        if (YFl == null) {
            synchronized (mn.class) {
                if (YFl == null) {
                    if (com.bytedance.sdk.openadsdk.core.settings.rkt.HVP()) {
                        i = com.bytedance.sdk.openadsdk.core.settings.rkt.JwO().rE();
                        Sg = true;
                    } else {
                        i = 4;
                    }
                    YFl = new ThreadPoolExecutor(i, Integer.MAX_VALUE, 30L, TimeUnit.SECONDS, new LinkedBlockingQueue());
                    Object[] objArr = new Object[2];
                    Integer.valueOf(i);
                }
            }
        }
        return YFl;
    }

    private static ThreadPoolExecutor GA() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = tN;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(tN)) {
                    tN = YFl("ad", tN);
                }
                vcVar = tN;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc pDU() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = vc;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(vc)) {
                    vc = YFl("cache", vc);
                }
                vcVar = vc;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc EH() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = AlY;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(AlY)) {
                    AlY = YFl("log", AlY);
                }
                vcVar = AlY;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc rkt() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = wN;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(wN)) {
                    wN = YFl("aidl", wN);
                }
                vcVar = wN;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc lG() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = qsH;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(qsH)) {
                    qsH = YFl("image", qsH);
                }
                vcVar = qsH;
            }
            return vcVar;
        }
        return vcVar2;
    }

    public static com.bytedance.sdk.component.qsH.tN.vc qsH() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = NjR;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(NjR)) {
                    NjR = YFl("express", NjR);
                }
                vcVar = NjR;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc Wwa() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = DSW;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(DSW)) {
                    DSW = YFl("io", DSW);
                }
                vcVar = DSW;
            }
            return vcVar;
        }
        return vcVar2;
    }

    public static com.bytedance.sdk.component.qsH.tN.vc NjR() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = eT;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(eT)) {
                    eT = YFl("monitor", eT);
                }
                vcVar = eT;
            }
            return vcVar;
        }
        return vcVar2;
    }

    public static com.bytedance.sdk.component.qsH.tN.vc nc() {
        com.bytedance.sdk.component.qsH.tN.vc vcVar;
        com.bytedance.sdk.component.qsH.tN.vc vcVar2 = nc;
        if (YFl(vcVar2)) {
            synchronized (mn.class) {
                if (YFl(nc)) {
                    nc = YFl("net", nc);
                }
                vcVar = nc;
            }
            return vcVar;
        }
        return vcVar2;
    }

    private static boolean YFl(com.bytedance.sdk.component.qsH.tN.vc vcVar) {
        if (vcVar != null) {
            return !vcVar.tN() && com.bytedance.sdk.openadsdk.core.settings.rkt.HVP();
        }
        return true;
    }

    public static boolean eT() {
        if (com.bytedance.sdk.openadsdk.core.settings.rkt.HVP()) {
            return com.bytedance.sdk.openadsdk.core.settings.rkt.JwO().SVa();
        }
        return true;
    }

    private static com.bytedance.sdk.component.qsH.tN.vc YFl(String str, com.bytedance.sdk.component.qsH.tN.vc vcVar) {
        vc.YFl YFl2 = YFl(str);
        if (vcVar == null) {
            return YFl2.YFl();
        }
        vcVar.YFl(YFl2);
        return vcVar;
    }

    private static vc.YFl YFl(String str) {
        vc.YFl Sg2 = Sg(str);
        try {
            if (com.bytedance.sdk.openadsdk.core.settings.rkt.HVP()) {
                Sg2.Sg(true);
                JSONObject Gmi = com.bytedance.sdk.openadsdk.core.settings.rkt.JwO().Gmi();
                JSONObject optJSONObject = Gmi != null ? Gmi.optJSONObject(str) : null;
                if (optJSONObject != null) {
                    Sg2.Sg(true);
                    if (optJSONObject.has("coreSize")) {
                        Sg2.YFl(optJSONObject.optInt("coreSize"));
                    }
                    if (optJSONObject.has("maxSize")) {
                        Sg2.Sg(optJSONObject.optInt("maxSize"));
                    }
                    if (optJSONObject.has("createSize")) {
                        Sg2.tN(optJSONObject.optInt("createSize"));
                    }
                    if (optJSONObject.has("keepAlive")) {
                        Sg2.YFl(optJSONObject.optInt("keepAlive"));
                    }
                    if (optJSONObject.has("allowCoreTimeOut")) {
                        Sg2.YFl(optJSONObject.optBoolean("allowCoreTimeOut"));
                    }
                    if (optJSONObject.has("reportLogThreshold")) {
                        Sg2.wN(optJSONObject.optInt("reportLogThreshold"));
                    }
                    if (optJSONObject.has("logTaskCount")) {
                        Sg2.AlY(optJSONObject.optInt("logTaskCount"));
                    }
                }
            }
        } catch (Throwable th) {
            th.getMessage();
        }
        return Sg2;
    }

    /* JADX WARN: Can't fix incorrect switch cases order, some code will duplicate */
    private static vc.YFl Sg(String str) {
        char c;
        if (TextUtils.isEmpty(str)) {
            str = "unknown";
        }
        vc.YFl yFl = new vc.YFl();
        str.hashCode();
        switch (str.hashCode()) {
            case -1308979344:
                if (str.equals("express")) {
                    c = 0;
                    break;
                }
                c = 65535;
                break;
            case 3107:
                if (str.equals("ad")) {
                    c = 1;
                    break;
                }
                c = 65535;
                break;
            case 3366:
                if (str.equals("io")) {
                    c = 2;
                    break;
                }
                c = 65535;
                break;
            case 107332:
                if (str.equals("log")) {
                    c = 3;
                    break;
                }
                c = 65535;
                break;
            case 108957:
                if (str.equals("net")) {
                    c = 4;
                    break;
                }
                c = 65535;
                break;
            case 2993840:
                if (str.equals("aidl")) {
                    c = 5;
                    break;
                }
                c = 65535;
                break;
            case 94416770:
                if (str.equals("cache")) {
                    c = 6;
                    break;
                }
                c = 65535;
                break;
            case 100313435:
                if (str.equals("image")) {
                    c = 7;
                    break;
                }
                c = 65535;
                break;
            case 1236319578:
                if (str.equals("monitor")) {
                    c = '\b';
                    break;
                }
                c = 65535;
                break;
            default:
                c = 65535;
                break;
        }
        switch (c) {
            case 0:
                return yFl.YFl(str).YFl(2).Sg(4).tN(0).YFl(10000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 1:
                return yFl.YFl(str).YFl(4).Sg(4).tN(0).YFl(20000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 2:
                return yFl.YFl(str).YFl(4).Sg(10).tN(0).YFl(20000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 3:
                return yFl.YFl(str).YFl(4).Sg(6).tN(2).YFl(20000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 4:
                return yFl.YFl(str).YFl(10).Sg(10).tN(0).YFl(10000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 5:
                return yFl.YFl(str).YFl(2).Sg(4).tN(0).YFl(10000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case 6:
                return yFl.YFl(str).YFl(0).Sg(0).tN(0).YFl(5000L).YFl(true).wN(-1).AlY(20).Sg(false);
            case 7:
                return yFl.YFl(str).YFl(3).Sg(3).tN(0).YFl(20000L).YFl(true).wN(-1).AlY(10).Sg(false);
            case '\b':
                return yFl.YFl(str).YFl(2).Sg(2).tN(0).YFl(10000L).YFl(true).wN(-1).AlY(10).Sg(false);
            default:
                return yFl.YFl(str).YFl(8).Sg(16).tN(2).YFl(20000L).YFl(true).wN(-1).AlY(10).Sg(false);
        }
    }
}