package zx2;
import com.meizu.cloud.pushsdk.notification.model.AdvanceSetting;
import java.lang.reflect.Method;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
import kotlin.Metadata;
import kotlin.coroutines.CoroutineContext;
import kotlin.ranges.RangesKt___RangesKt;
import kotlin.text.StringsKt__StringNumberConversionsKt;
@Metadata(bv = {}, d1 = {"\u0000H\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0006\bÀ\u0002\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u001b\u0010\u001cJ#\u0010\u0007\u001a\u00020\u00062\n\u0010\u0003\u001a\u0006\u0012\u0002\b\u00030\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0000¢\u0006\u0004\b\u0007\u0010\bJ\u001c\u0010\u000f\u001a\u00020\u000e2\u0006\u0010\n\u001a\u00020\t2\n\u0010\r\u001a\u00060\u000bj\u0002`\fH\u0016J\b\u0010\u0011\u001a\u00020\u0010H\u0016J\b\u0010\u0012\u001a\u00020\u000eH\u0016J\b\u0010\u0013\u001a\u00020\u0004H\u0002J\b\u0010\u0014\u001a\u00020\u0004H\u0002J\b\u0010\u0016\u001a\u00020\u0015H\u0002R\u0014\u0010\u001a\u001a\u00020\u00178BX\u0004¢\u0006\u0006\u001a\u0004\b\u0018\u0010\u0019¨\u0006\u001d"}, d2 = {"Lzx2/o;", "Lzx2/t0;", "Ljava/lang/Class;", "fjpClass", "Ljava/util/concurrent/ExecutorService;", "executor", "", "I", "(Ljava/lang/Class;Ljava/util/concurrent/ExecutorService;)Z", "Lkotlin/coroutines/CoroutineContext;", "context", "Ljava/lang/Runnable;", "Lkotlinx/coroutines/Runnable;", "block", "", "dispatch", "", "toString", "close", "F", "E", "Ljava/util/concurrent/Executor;", "G", "", "H", "()I", "parallelism", "<init>", "()V", "kotlinx-coroutines-core"}, k = 1, mv = {1, 4, 0})
/* compiled from: CommonPool.kt */
public final class o extends t0 {
/* renamed from: b reason: collision with root package name */
public static final int f163948b;
/* renamed from: c reason: collision with root package name */
public static boolean f163949c;
/* renamed from: d reason: collision with root package name */
public static final o f163950d = new o();
private static volatile Executor pool;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u0010\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0000\u001a\u00020\u00012\u000e\u0010\u0002\u001a\n \u0004*\u0004\u0018\u00010\u00030\u0003H\n¢\u0006\u0002\b\u0005"}, d2 = {"<anonymous>", "Ljava/lang/Thread;", AdvanceSetting.NETWORK_TYPE, "Ljava/lang/Runnable;", "kotlin.jvm.PlatformType", "newThread"}, k = 3, mv = {1, 1, 16})
/* compiled from: CommonPool.kt */
public static final class a implements ThreadFactory {
/* renamed from: a reason: collision with root package name */
public final /* synthetic */ AtomicInteger f163951a;
public a(AtomicInteger atomicInteger) {
this.f163951a = atomicInteger;
}
public final Thread newThread(Runnable runnable) {
Thread thread = new Thread(runnable, "CommonPool-worker-" + this.f163951a.incrementAndGet());
thread.setDaemon(true);
return thread;
}
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\b\n\u0000\n\u0002\u0010\u0002\n\u0000\u0010\u0000\u001a\u00020\u0001H\n¢\u0006\u0002\b\u0002"}, d2 = {"<anonymous>", "", "run"}, k = 3, mv = {1, 1, 16})
/* compiled from: CommonPool.kt */
public static final class b implements Runnable {
/* renamed from: a reason: collision with root package name */
public static final b f163952a = new b();
public final void run() {
}
}
static {
String str;
int i10;
try {
str = System.getProperty("kotlinx.coroutines.default.parallelism");
} catch (Throwable unused) {
str = null;
}
if (str != null) {
Integer num = StringsKt__StringNumberConversionsKt.toIntOrNull(str);
if (num == null || num.intValue() < 1) {
throw new IllegalStateException(("Expected positive number in kotlinx.coroutines.default.parallelism, but has " + str).toString());
}
i10 = num.intValue();
} else {
i10 = -1;
}
f163948b = i10;
}
public final ExecutorService E() {
return Executors.newFixedThreadPool(H(), new a(new AtomicInteger()));
}
public final ExecutorService F() {
Class<?> cls;
ExecutorService executorService;
if (System.getSecurityManager() != null) {
return E();
}
ExecutorService executorService2 = null;
try {
cls = Class.forName("java.util.concurrent.ForkJoinPool");
} catch (Throwable unused) {
cls = null;
}
if (cls == null) {
return E();
}
if (!f163949c && f163948b < 0) {
try {
Method method = cls.getMethod("commonPool", new Class[0]);
Object invoke = method != null ? method.invoke(null, new Object[0]) : null;
if (!(invoke instanceof ExecutorService)) {
invoke = null;
}
executorService = (ExecutorService) invoke;
} catch (Throwable unused2) {
executorService = null;
}
if (executorService != null) {
if (!f163950d.I(cls, executorService)) {
executorService = null;
}
if (executorService != null) {
return executorService;
}
}
}
try {
Object newInstance = cls.getConstructor(Integer.TYPE).newInstance(Integer.valueOf(f163950d.H()));
if (!(newInstance instanceof ExecutorService)) {
newInstance = null;
}
executorService2 = (ExecutorService) newInstance;
} catch (Throwable unused3) {
}
if (executorService2 != null) {
return executorService2;
}
return E();
}
public final synchronized Executor G() {
Executor executor;
executor = pool;
if (executor == null) {
executor = F();
pool = executor;
}
return executor;
}
public final int H() {
Integer valueOf = Integer.valueOf(f163948b);
if (!(valueOf.intValue() > 0)) {
valueOf = null;
}
if (valueOf != null) {
return valueOf.intValue();
}
return RangesKt___RangesKt.coerceAtLeast(Runtime.getRuntime().availableProcessors() - 1, 1);
}
public final boolean I(Class<?> cls, ExecutorService executorService) {
executorService.submit(b.f163952a);
Integer num = null;
try {
Object invoke = cls.getMethod("getPoolSize", new Class[0]).invoke(executorService, new Object[0]);
if (!(invoke instanceof Integer)) {
invoke = null;
}
num = (Integer) invoke;
} catch (Throwable unused) {
}
if (num == null || num.intValue() < 1) {
return false;
}
return true;
}
@Override // java.io.Closeable, java.lang.AutoCloseable
public void close() {
throw new IllegalStateException("Close cannot be invoked on CommonPool".toString());
}
@Override // zx2.w
public void dispatch(CoroutineContext coroutineContext, Runnable runnable) {
Runnable runnable2;
try {
Executor executor = pool;
if (executor == null) {
executor = G();
}
q1 a14 = r1.a();
if (a14 == null || (runnable2 = a14.d(runnable)) == null) {
runnable2 = runnable;
}
executor.execute(runnable2);
} catch (RejectedExecutionException unused) {
q1 a15 = r1.a();
if (a15 != null) {
a15.a();
}
g0.f163908g.T(runnable);
}
}
@Override // zx2.w
public String toString() {
return "CommonPool";
}
}