package kotlinx.coroutines.scheduling; import com.seewo.vcommons.system.onoffsetting.TimeSwitchSQLHelper; import java.io.Closeable; import java.util.ArrayList; import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicLongFieldUpdater; import java.util.concurrent.locks.LockSupport; import kotlin.Metadata; import kotlin.Unit; import kotlin.jvm.internal.DefaultConstructorMarker; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.LongCompanionObject; import kotlin.random.Random; import kotlin.ranges.RangesKt; import kotlinx.coroutines.AbstractTimeSource; import kotlinx.coroutines.AbstractTimeSourceKt; import kotlinx.coroutines.DebugKt; import kotlinx.coroutines.DebugStringsKt; import kotlinx.coroutines.internal.ResizableAtomicArray; import kotlinx.coroutines.internal.Symbol; /* JADX INFO: compiled from: CoroutineScheduler.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000b\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0006\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b-\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\u0018\u0002\b\u0000\u0018\u0000 X2\u00020\\2\u00020]:\u0003XYZB+\u0012\u0006\u0010\u0002\u001a\u00020\u0001\u0012\u0006\u0010\u0003\u001a\u00020\u0001\u0012\b\b\u0002\u0010\u0005\u001a\u00020\u0004\u0012\b\b\u0002\u0010\u0007\u001a\u00020\u0006¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\r\u001a\u00020\f2\u0006\u0010\u000b\u001a\u00020\nH\u0002¢\u0006\u0004\b\r\u0010\u000eJ\u0018\u0010\u0010\u001a\u00020\u00012\u0006\u0010\u000f\u001a\u00020\u0004H\u0086\b¢\u0006\u0004\b\u0010\u0010\u0011J\u0018\u0010\u0012\u001a\u00020\u00012\u0006\u0010\u000f\u001a\u00020\u0004H\u0082\b¢\u0006\u0004\b\u0012\u0010\u0011J\u000f\u0010\u0014\u001a\u00020\u0013H\u0016¢\u0006\u0004\b\u0014\u0010\u0015J\u000f\u0010\u0016\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\u0016\u0010\u0017J!\u0010\u001d\u001a\u00020\n2\n\u0010\u001a\u001a\u00060\u0018j\u0002`\u00192\u0006\u0010\u001c\u001a\u00020\u001b¢\u0006\u0004\b\u001d\u0010\u001eJ\u0018\u0010\u001f\u001a\u00020\u00012\u0006\u0010\u000f\u001a\u00020\u0004H\u0082\b¢\u0006\u0004\b\u001f\u0010\u0011J\u0015\u0010!\u001a\b\u0018\u00010 R\u00020\u0000H\u0002¢\u0006\u0004\b!\u0010\"J\u0010\u0010#\u001a\u00020\u0013H\u0082\b¢\u0006\u0004\b#\u0010\u0015J\u0010\u0010$\u001a\u00020\u0001H\u0082\b¢\u0006\u0004\b$\u0010\u0017J-\u0010&\u001a\u00020\u00132\n\u0010\u001a\u001a\u00060\u0018j\u0002`\u00192\b\b\u0002\u0010\u001c\u001a\u00020\u001b2\b\b\u0002\u0010%\u001a\u00020\f¢\u0006\u0004\b&\u0010'J\u001b\u0010)\u001a\u00020\u00132\n\u0010(\u001a\u00060\u0018j\u0002`\u0019H\u0016¢\u0006\u0004\b)\u0010*J\u0010\u0010+\u001a\u00020\u0004H\u0082\b¢\u0006\u0004\b+\u0010,J\u0010\u0010-\u001a\u00020\u0001H\u0082\b¢\u0006\u0004\b-\u0010\u0017J\u001b\u0010/\u001a\u00020\u00012\n\u0010.\u001a\u00060 R\u00020\u0000H\u0002¢\u0006\u0004\b/\u00100J\u0015\u00101\u001a\b\u0018\u00010 R\u00020\u0000H\u0002¢\u0006\u0004\b1\u0010\"J\u0019\u00102\u001a\u00020\f2\n\u0010.\u001a\u00060 R\u00020\u0000¢\u0006\u0004\b2\u00103J)\u00106\u001a\u00020\u00132\n\u0010.\u001a\u00060 R\u00020\u00002\u0006\u00104\u001a\u00020\u00012\u0006\u00105\u001a\u00020\u0001¢\u0006\u0004\b6\u00107J\u0010\u00108\u001a\u00020\u0004H\u0082\b¢\u0006\u0004\b8\u0010,J\u0015\u00109\u001a\u00020\u00132\u0006\u0010\u000b\u001a\u00020\n¢\u0006\u0004\b9\u0010:J\u0015\u0010<\u001a\u00020\u00132\u0006\u0010;\u001a\u00020\u0004¢\u0006\u0004\b<\u0010=J\u0017\u0010?\u001a\u00020\u00132\u0006\u0010>\u001a\u00020\fH\u0002¢\u0006\u0004\b?\u0010@J\r\u0010A\u001a\u00020\u0013¢\u0006\u0004\bA\u0010\u0015J\u000f\u0010B\u001a\u00020\u0006H\u0016¢\u0006\u0004\bB\u0010CJ\u0010\u0010D\u001a\u00020\fH\u0082\b¢\u0006\u0004\bD\u0010EJ\u0019\u0010F\u001a\u00020\f2\b\b\u0002\u0010\u000f\u001a\u00020\u0004H\u0002¢\u0006\u0004\bF\u0010GJ\u000f\u0010H\u001a\u00020\fH\u0002¢\u0006\u0004\bH\u0010EJ+\u0010I\u001a\u0004\u0018\u00010\n*\b\u0018\u00010 R\u00020\u00002\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010%\u001a\u00020\fH\u0002¢\u0006\u0004\bI\u0010JR\u0015\u0010\u0010\u001a\u00020\u00018Â\u0002X\u0082\u0004¢\u0006\u0006\u001a\u0004\bK\u0010\u0017R\u0014\u0010\u0002\u001a\u00020\u00018\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\b\u0002\u0010LR\u0015\u0010\u001f\u001a\u00020\u00018Â\u0002X\u0082\u0004¢\u0006\u0006\u001a\u0004\bM\u0010\u0017R\u0014\u0010O\u001a\u00020N8\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\bO\u0010PR\u0014\u0010Q\u001a\u00020N8\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\bQ\u0010PR\u0014\u0010\u0005\u001a\u00020\u00048\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010RR\u0011\u0010S\u001a\u00020\f8F¢\u0006\u0006\u001a\u0004\bS\u0010ER\u0014\u0010\u0003\u001a\u00020\u00018\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010LR\u0014\u0010\u0007\u001a\u00020\u00068\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\b\u0007\u0010TR\u001e\u0010V\u001a\f\u0012\b\u0012\u00060 R\u00020\u00000U8\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\bV\u0010W¨\u0006["}, d2 = {"Lkotlinx/coroutines/scheduling/CoroutineScheduler;", "", "corePoolSize", "maxPoolSize", "", "idleWorkerKeepAliveNs", "", "schedulerName", "", "(IIJLjava/lang/String;)V", "Lkotlinx/coroutines/scheduling/Task;", TimeSwitchSQLHelper.TABLE_TASK, "", "addToGlobalQueue", "(Lkotlinx/coroutines/scheduling/Task;)Z", "state", "availableCpuPermits", "(J)I", "blockingTasks", "", "close", "()V", "createNewWorker", "()I", "Ljava/lang/Runnable;", "Lkotlinx/coroutines/Runnable;", "block", "Lkotlinx/coroutines/scheduling/TaskContext;", "taskContext", "createTask", "(Ljava/lang/Runnable;Lkotlinx/coroutines/scheduling/TaskContext;)Lkotlinx/coroutines/scheduling/Task;", "createdWorkers", "Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;", "currentWorker", "()Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;", "decrementBlockingTasks", "decrementCreatedWorkers", "tailDispatch", "dispatch", "(Ljava/lang/Runnable;Lkotlinx/coroutines/scheduling/TaskContext;Z)V", "command", "execute", "(Ljava/lang/Runnable;)V", "incrementBlockingTasks", "()J", "incrementCreatedWorkers", "worker", "parkedWorkersStackNextIndex", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;)I", "parkedWorkersStackPop", "parkedWorkersStackPush", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;)Z", "oldIndex", "newIndex", "parkedWorkersStackTopUpdate", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;II)V", "releaseCpuPermit", "runSafely", "(Lkotlinx/coroutines/scheduling/Task;)V", "timeout", "shutdown", "(J)V", "skipUnpark", "signalBlockingWork", "(Z)V", "signalCpuWork", "toString", "()Ljava/lang/String;", "tryAcquireCpuPermit", "()Z", "tryCreateWorker", "(J)Z", "tryUnpark", "submitToLocalQueue", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;Lkotlinx/coroutines/scheduling/Task;Z)Lkotlinx/coroutines/scheduling/Task;", "getAvailableCpuPermits", "I", "getCreatedWorkers", "Lkotlinx/coroutines/scheduling/GlobalQueue;", "globalBlockingQueue", "Lkotlinx/coroutines/scheduling/GlobalQueue;", "globalCpuQueue", "J", "isTerminated", "Ljava/lang/String;", "Lkotlinx/coroutines/internal/ResizableAtomicArray;", "workers", "Lkotlinx/coroutines/internal/ResizableAtomicArray;", "Companion", "Worker", "WorkerState", "kotlinx-coroutines-core", "Ljava/util/concurrent/Executor;", "Ljava/io/Closeable;"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class CoroutineScheduler implements Executor, Closeable { private static final long BLOCKING_MASK = 4398044413952L; private static final int BLOCKING_SHIFT = 21; private static final int CLAIMED = 0; private static final long CPU_PERMITS_MASK = 9223367638808264704L; private static final int CPU_PERMITS_SHIFT = 42; private static final long CREATED_MASK = 2097151; public static final int MAX_SUPPORTED_POOL_SIZE = 2097150; public static final int MIN_SUPPORTED_POOL_SIZE = 1; private static final int PARKED = -1; private static final long PARKED_INDEX_MASK = 2097151; private static final long PARKED_VERSION_INC = 2097152; private static final long PARKED_VERSION_MASK = -2097152; private static final int TERMINATED = 1; private volatile /* synthetic */ int _isTerminated; volatile /* synthetic */ long controlState; public final int corePoolSize; public final GlobalQueue globalBlockingQueue; public final GlobalQueue globalCpuQueue; public final long idleWorkerKeepAliveNs; public final int maxPoolSize; private volatile /* synthetic */ long parkedWorkersStack; public final String schedulerName; public final ResizableAtomicArray workers; public static final Symbol NOT_IN_STACK = new Symbol("NOT_IN_STACK"); private static final /* synthetic */ AtomicLongFieldUpdater parkedWorkersStack$FU = AtomicLongFieldUpdater.newUpdater(CoroutineScheduler.class, "parkedWorkersStack"); static final /* synthetic */ AtomicLongFieldUpdater controlState$FU = AtomicLongFieldUpdater.newUpdater(CoroutineScheduler.class, "controlState"); private static final /* synthetic */ AtomicIntegerFieldUpdater _isTerminated$FU = AtomicIntegerFieldUpdater.newUpdater(CoroutineScheduler.class, "_isTerminated"); /* JADX INFO: compiled from: CoroutineScheduler.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) public /* synthetic */ class WhenMappings { public static final /* synthetic */ int[] $EnumSwitchMapping$0; static { int[] iArr = new int[WorkerState.values().length]; iArr[WorkerState.PARKING.ordinal()] = 1; iArr[WorkerState.BLOCKING.ordinal()] = 2; iArr[WorkerState.CPU_ACQUIRED.ordinal()] = 3; iArr[WorkerState.DORMANT.ordinal()] = 4; iArr[WorkerState.TERMINATED.ordinal()] = 5; $EnumSwitchMapping$0 = iArr; } } /* JADX INFO: compiled from: CoroutineScheduler.kt */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u0010\n\u0002\b\u0007\b\u0086\u0001\u0018\u00002\b\u0012\u0004\u0012\u00020\u00000\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002j\u0002\b\u0003j\u0002\b\u0004j\u0002\b\u0005j\u0002\b\u0006j\u0002\b\u0007¨\u0006\b"}, d2 = {"Lkotlinx/coroutines/scheduling/CoroutineScheduler$WorkerState;", "", "(Ljava/lang/String;I)V", "CPU_ACQUIRED", "BLOCKING", "PARKING", "DORMANT", "TERMINATED", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) public enum WorkerState { CPU_ACQUIRED, BLOCKING, PARKING, DORMANT, TERMINATED } private final int blockingTasks(long state) { return (int) ((state & BLOCKING_MASK) >> 21); } private final int createdWorkers(long state) { return (int) (state & 2097151); } public final int availableCpuPermits(long state) { return (int) ((state & CPU_PERMITS_MASK) >> 42); } public CoroutineScheduler(int i, int i2, long j, String str) { this.corePoolSize = i; this.maxPoolSize = i2; this.idleWorkerKeepAliveNs = j; this.schedulerName = str; if (i < 1) { throw new IllegalArgumentException(("Core pool size " + i + " should be at least 1").toString()); } if (i2 < i) { throw new IllegalArgumentException(("Max pool size " + i2 + " should be greater than or equals to core pool size " + i).toString()); } if (i2 > 2097150) { throw new IllegalArgumentException(("Max pool size " + i2 + " should not exceed maximal supported number of threads 2097150").toString()); } if (j <= 0) { throw new IllegalArgumentException(("Idle worker keep alive time " + j + " must be positive").toString()); } this.globalCpuQueue = new GlobalQueue(); this.globalBlockingQueue = new GlobalQueue(); this.parkedWorkersStack = 0L; this.workers = new ResizableAtomicArray<>(i + 1); this.controlState = ((long) i) << 42; this._isTerminated = 0; } public /* synthetic */ CoroutineScheduler(int i, int i2, long j, String str, int i3, DefaultConstructorMarker defaultConstructorMarker) { this(i, i2, (i3 & 4) != 0 ? TasksKt.IDLE_WORKER_KEEP_ALIVE_NS : j, (i3 & 8) != 0 ? TasksKt.DEFAULT_SCHEDULER_NAME : str); } public final boolean parkedWorkersStackPush(Worker worker) { long j; long j2; int indexInArray; if (worker.getNextParkedWorker() != NOT_IN_STACK) { return false; } do { j = this.parkedWorkersStack; int i = (int) (2097151 & j); j2 = (PARKED_VERSION_INC + j) & PARKED_VERSION_MASK; indexInArray = worker.getIndexInArray(); if (DebugKt.getASSERTIONS_ENABLED() && indexInArray == 0) { throw new AssertionError(); } worker.setNextParkedWorker(this.workers.get(i)); } while (!parkedWorkersStack$FU.compareAndSet(this, j, j2 | ((long) indexInArray))); return true; } private final int parkedWorkersStackNextIndex(Worker worker) { Object nextParkedWorker = worker.getNextParkedWorker(); while (nextParkedWorker != NOT_IN_STACK) { if (nextParkedWorker == null) { return 0; } Worker worker2 = (Worker) nextParkedWorker; int indexInArray = worker2.getIndexInArray(); if (indexInArray != 0) { return indexInArray; } nextParkedWorker = worker2.getNextParkedWorker(); } return -1; } private final int getCreatedWorkers() { return (int) (this.controlState & 2097151); } private final int getAvailableCpuPermits() { return (int) ((this.controlState & CPU_PERMITS_MASK) >> 42); } private final int incrementCreatedWorkers() { return (int) (controlState$FU.incrementAndGet(this) & 2097151); } private final int decrementCreatedWorkers() { return (int) (controlState$FU.getAndDecrement(this) & 2097151); } private final long incrementBlockingTasks() { return controlState$FU.addAndGet(this, PARKED_VERSION_INC); } private final void decrementBlockingTasks() { controlState$FU.addAndGet(this, PARKED_VERSION_MASK); } private final long releaseCpuPermit() { return controlState$FU.addAndGet(this, 4398046511104L); } /* JADX WARN: Type inference failed for: r0v1, types: [boolean, int] */ public final boolean isTerminated() { return this._isTerminated; } @Override // java.util.concurrent.Executor public void execute(Runnable command) { dispatch$default(this, command, null, false, 6, null); } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { shutdown(10000L); } /* JADX WARN: Removed duplicated region for block: B:31:0x006b */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final void shutdown(long r8) { /* r7 = this; java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = kotlinx.coroutines.scheduling.CoroutineScheduler._isTerminated$FU r1 = 0 r2 = 1 boolean r0 = r0.compareAndSet(r7, r1, r2) if (r0 != 0) goto Lb return Lb: kotlinx.coroutines.scheduling.CoroutineScheduler$Worker r0 = r7.currentWorker() kotlinx.coroutines.internal.ResizableAtomicArray r1 = r7.workers monitor-enter(r1) long r3 = r7.controlState // Catch: java.lang.Throwable -> Lae r5 = 2097151(0x1fffff, double:1.0361303E-317) long r3 = r3 & r5 int r3 = (int) r3 monitor-exit(r1) if (r2 > r3) goto L59 r1 = r2 L1d: kotlinx.coroutines.internal.ResizableAtomicArray r4 = r7.workers java.lang.Object r4 = r4.get(r1) kotlin.jvm.internal.Intrinsics.checkNotNull(r4) kotlinx.coroutines.scheduling.CoroutineScheduler$Worker r4 = (kotlinx.coroutines.scheduling.CoroutineScheduler.Worker) r4 if (r4 == r0) goto L54 L2a: boolean r5 = r4.isAlive() if (r5 == 0) goto L3a r5 = r4 java.lang.Thread r5 = (java.lang.Thread) r5 java.util.concurrent.locks.LockSupport.unpark(r5) r4.join(r8) goto L2a L3a: kotlinx.coroutines.scheduling.CoroutineScheduler$WorkerState r5 = r4.state boolean r6 = kotlinx.coroutines.DebugKt.getASSERTIONS_ENABLED() if (r6 == 0) goto L4d kotlinx.coroutines.scheduling.CoroutineScheduler$WorkerState r6 = kotlinx.coroutines.scheduling.CoroutineScheduler.WorkerState.TERMINATED if (r5 != r6) goto L47 goto L4d L47: java.lang.AssertionError r7 = new java.lang.AssertionError r7.() throw r7 L4d: kotlinx.coroutines.scheduling.WorkQueue r4 = r4.localQueue kotlinx.coroutines.scheduling.GlobalQueue r5 = r7.globalBlockingQueue r4.offloadAllWorkTo(r5) L54: if (r1 == r3) goto L59 int r1 = r1 + 1 goto L1d L59: kotlinx.coroutines.scheduling.GlobalQueue r8 = r7.globalBlockingQueue r8.close() kotlinx.coroutines.scheduling.GlobalQueue r8 = r7.globalCpuQueue r8.close() L63: if (r0 == 0) goto L6b kotlinx.coroutines.scheduling.Task r8 = r0.findTask(r2) if (r8 != 0) goto Laa L6b: kotlinx.coroutines.scheduling.GlobalQueue r8 = r7.globalCpuQueue java.lang.Object r8 = r8.removeFirstOrNull() kotlinx.coroutines.scheduling.Task r8 = (kotlinx.coroutines.scheduling.Task) r8 if (r8 != 0) goto Laa kotlinx.coroutines.scheduling.GlobalQueue r8 = r7.globalBlockingQueue java.lang.Object r8 = r8.removeFirstOrNull() kotlinx.coroutines.scheduling.Task r8 = (kotlinx.coroutines.scheduling.Task) r8 if (r8 != 0) goto Laa if (r0 == 0) goto L86 kotlinx.coroutines.scheduling.CoroutineScheduler$WorkerState r8 = kotlinx.coroutines.scheduling.CoroutineScheduler.WorkerState.TERMINATED r0.tryReleaseCpu(r8) L86: boolean r8 = kotlinx.coroutines.DebugKt.getASSERTIONS_ENABLED() if (r8 == 0) goto La3 long r8 = r7.controlState r0 = 9223367638808264704(0x7ffffc0000000000, double:NaN) long r8 = r8 & r0 r0 = 42 long r8 = r8 >> r0 int r8 = (int) r8 int r9 = r7.corePoolSize if (r8 != r9) goto L9d goto La3 L9d: java.lang.AssertionError r7 = new java.lang.AssertionError r7.() throw r7 La3: r8 = 0 r7.parkedWorkersStack = r8 r7.controlState = r8 return Laa: r7.runSafely(r8) goto L63 Lae: r7 = move-exception monitor-exit(r1) throw r7 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.scheduling.CoroutineScheduler.shutdown(long):void"); } public static /* synthetic */ void dispatch$default(CoroutineScheduler coroutineScheduler, Runnable runnable, TaskContext taskContext, boolean z, int i, Object obj) { if ((i & 2) != 0) { taskContext = TasksKt.NonBlockingContext; } if ((i & 4) != 0) { z = false; } coroutineScheduler.dispatch(runnable, taskContext, z); } public final void dispatch(Runnable block, TaskContext taskContext, boolean tailDispatch) { AbstractTimeSource timeSource = AbstractTimeSourceKt.getTimeSource(); if (timeSource != null) { timeSource.trackTask(); } Task taskCreateTask = createTask(block, taskContext); Worker workerCurrentWorker = currentWorker(); Task taskSubmitToLocalQueue = submitToLocalQueue(workerCurrentWorker, taskCreateTask, tailDispatch); if (taskSubmitToLocalQueue != null && !addToGlobalQueue(taskSubmitToLocalQueue)) { throw new RejectedExecutionException(this.schedulerName + " was terminated"); } boolean z = tailDispatch && workerCurrentWorker != null; if (taskCreateTask.taskContext.getTaskMode() != 0) { signalBlockingWork(z); } else { if (z) { return; } signalCpuWork(); } } public final Task createTask(Runnable block, TaskContext taskContext) { long jNanoTime = TasksKt.schedulerTimeSource.nanoTime(); if (block instanceof Task) { Task task = (Task) block; task.submissionTime = jNanoTime; task.taskContext = taskContext; return task; } return new TaskImpl(block, jNanoTime, taskContext); } public final void signalCpuWork() { if (tryUnpark() || tryCreateWorker$default(this, 0L, 1, null)) { return; } tryUnpark(); } static /* synthetic */ boolean tryCreateWorker$default(CoroutineScheduler coroutineScheduler, long j, int i, Object obj) { if ((i & 1) != 0) { j = coroutineScheduler.controlState; } return coroutineScheduler.tryCreateWorker(j); } private final boolean tryCreateWorker(long state) { if (RangesKt.coerceAtLeast(((int) (2097151 & state)) - ((int) ((state & BLOCKING_MASK) >> 21)), 0) < this.corePoolSize) { int iCreateNewWorker = createNewWorker(); if (iCreateNewWorker == 1 && this.corePoolSize > 1) { createNewWorker(); } if (iCreateNewWorker > 0) { return true; } } return false; } private final boolean tryUnpark() { Worker workerParkedWorkersStackPop; do { workerParkedWorkersStackPop = parkedWorkersStackPop(); if (workerParkedWorkersStackPop == null) { return false; } } while (!Worker.workerCtl$FU.compareAndSet(workerParkedWorkersStackPop, -1, 0)); LockSupport.unpark(workerParkedWorkersStackPop); return true; } private final int createNewWorker() { synchronized (this.workers) { if (isTerminated()) { return -1; } long j = this.controlState; int i = (int) (j & 2097151); int iCoerceAtLeast = RangesKt.coerceAtLeast(i - ((int) ((j & BLOCKING_MASK) >> 21)), 0); if (iCoerceAtLeast >= this.corePoolSize) { return 0; } if (i >= this.maxPoolSize) { return 0; } int i2 = ((int) (this.controlState & 2097151)) + 1; if (i2 <= 0 || this.workers.get(i2) != null) { throw new IllegalArgumentException("Failed requirement.".toString()); } Worker worker = new Worker(this, i2); this.workers.setSynchronized(i2, worker); if (i2 != ((int) (2097151 & controlState$FU.incrementAndGet(this)))) { throw new IllegalArgumentException("Failed requirement.".toString()); } worker.start(); return iCoerceAtLeast + 1; } } private final Task submitToLocalQueue(Worker worker, Task task, boolean z) { if (worker == null || worker.state == WorkerState.TERMINATED) { return task; } if (task.taskContext.getTaskMode() == 0 && worker.state == WorkerState.BLOCKING) { return task; } worker.mayHaveLocalTasks = true; return worker.localQueue.add(task, z); } private final Worker currentWorker() { Thread threadCurrentThread = Thread.currentThread(); Worker worker = threadCurrentThread instanceof Worker ? (Worker) threadCurrentThread : null; if (worker == null || !Intrinsics.areEqual(CoroutineScheduler.this, this)) { return null; } return worker; } public String toString() { ArrayList arrayList = new ArrayList(); int iCurrentLength = this.workers.currentLength(); int i = 0; int i2 = 0; int i3 = 0; int i4 = 0; int i5 = 0; for (int i6 = 1; i6 < iCurrentLength; i6++) { Worker worker = this.workers.get(i6); if (worker != null) { int size$kotlinx_coroutines_core = worker.localQueue.getSize$kotlinx_coroutines_core(); int i7 = WhenMappings.$EnumSwitchMapping$0[worker.state.ordinal()]; if (i7 == 1) { i3++; } else if (i7 == 2) { i2++; arrayList.add(new StringBuilder().append(size$kotlinx_coroutines_core).append('b').toString()); } else if (i7 == 3) { i++; arrayList.add(new StringBuilder().append(size$kotlinx_coroutines_core).append('c').toString()); } else if (i7 == 4) { i4++; if (size$kotlinx_coroutines_core > 0) { arrayList.add(new StringBuilder().append(size$kotlinx_coroutines_core).append('d').toString()); } } else if (i7 == 5) { i5++; } } } long j = this.controlState; StringBuilder sb = new StringBuilder(); sb.append(this.schedulerName).append('@').append(DebugStringsKt.getHexAddress(this)).append("[Pool Size {core = ").append(this.corePoolSize).append(", max = ").append(this.maxPoolSize).append("}, Worker States {CPU = ").append(i).append(", blocking = ").append(i2).append(", parked = ").append(i3).append(", dormant = ").append(i4).append(", terminated = ").append(i5).append("}, running workers queues = ").append(arrayList).append(", global CPU queue size = ").append(this.globalCpuQueue.getSize()).append(", global blocking queue size = ").append(this.globalBlockingQueue.getSize()); sb.append(", Control State {created workers= ").append((int) (2097151 & j)).append(", blocking tasks = ").append((int) ((BLOCKING_MASK & j) >> 21)).append(", CPUs acquired = ").append(this.corePoolSize - ((int) ((CPU_PERMITS_MASK & j) >> 42))).append("}]"); return sb.toString(); } public final void runSafely(Task task) { try { task.run(); } catch (Throwable th) { try { Thread threadCurrentThread = Thread.currentThread(); threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, th); AbstractTimeSource timeSource = AbstractTimeSourceKt.getTimeSource(); if (timeSource == null) { } } finally { AbstractTimeSource timeSource2 = AbstractTimeSourceKt.getTimeSource(); if (timeSource2 != null) { timeSource2.unTrackTask(); } } } } /* JADX INFO: compiled from: CoroutineScheduler.kt */ @Metadata(d1 = {"\u0000P\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0005\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0013\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\b\u0080\u0004\u0018\u00002\u00020GB\u0011\b\u0016\u0012\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0003\u0010\u0004B\t\b\u0002¢\u0006\u0004\b\u0003\u0010\u0005J\u0017\u0010\b\u001a\u00020\u00072\u0006\u0010\u0006\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\n\u001a\u00020\u00072\u0006\u0010\u0006\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\n\u0010\tJ\u0017\u0010\r\u001a\u00020\u00072\u0006\u0010\f\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\r\u0010\u000eJ\u0019\u0010\u0011\u001a\u0004\u0018\u00010\u000b2\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b\u0011\u0010\u0012J\u0017\u0010\u0013\u001a\u0004\u0018\u00010\u000b2\u0006\u0010\u0010\u001a\u00020\u000f¢\u0006\u0004\b\u0013\u0010\u0012J\u0017\u0010\u0015\u001a\u00020\u00072\u0006\u0010\u0014\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\u0015\u0010\tJ\u000f\u0010\u0016\u001a\u00020\u000fH\u0002¢\u0006\u0004\b\u0016\u0010\u0017J\u0015\u0010\u0019\u001a\u00020\u00012\u0006\u0010\u0018\u001a\u00020\u0001¢\u0006\u0004\b\u0019\u0010\u001aJ\u000f\u0010\u001b\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\u001b\u0010\u001cJ\u0011\u0010\u001d\u001a\u0004\u0018\u00010\u000bH\u0002¢\u0006\u0004\b\u001d\u0010\u001eJ\u000f\u0010\u001f\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\u001f\u0010\u001cJ\u000f\u0010 \u001a\u00020\u0007H\u0002¢\u0006\u0004\b \u0010\u001cJ\u000f\u0010!\u001a\u00020\u000fH\u0002¢\u0006\u0004\b!\u0010\u0017J\u000f\u0010\"\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\"\u0010\u001cJ\u0015\u0010%\u001a\u00020\u000f2\u0006\u0010$\u001a\u00020#¢\u0006\u0004\b%\u0010&J\u0019\u0010(\u001a\u0004\u0018\u00010\u000b2\u0006\u0010'\u001a\u00020\u000fH\u0002¢\u0006\u0004\b(\u0010\u0012J\u000f\u0010)\u001a\u00020\u0007H\u0002¢\u0006\u0004\b)\u0010\u001cR*\u0010*\u001a\u00020\u00012\u0006\u0010\u0002\u001a\u00020\u00018\u0006@FX\u0086\u000e¢\u0006\u0012\n\u0004\b*\u0010+\u001a\u0004\b,\u0010-\"\u0004\b.\u0010\tR\u0014\u00100\u001a\u00020/8\u0006X\u0087\u0004¢\u0006\u0006\n\u0004\b0\u00101R\u0016\u00102\u001a\u00020\u000f8\u0006@\u0006X\u0087\u000e¢\u0006\u0006\n\u0004\b2\u00103R\u0016\u00105\u001a\u0002048\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b5\u00106R$\u00108\u001a\u0004\u0018\u0001078\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b8\u00109\u001a\u0004\b:\u0010;\"\u0004\b<\u0010=R\u0016\u0010>\u001a\u00020\u00018\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b>\u0010+R\u0012\u0010B\u001a\u00020?8Æ\u0002¢\u0006\u0006\u001a\u0004\b@\u0010AR\u0016\u0010C\u001a\u00020#8\u0006@\u0006X\u0087\u000e¢\u0006\u0006\n\u0004\bC\u0010DR\u0016\u0010E\u001a\u0002048\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bE\u00106¨\u0006F"}, d2 = {"Lkotlinx/coroutines/scheduling/CoroutineScheduler$Worker;", "", "index", "", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler;I)V", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler;)V", "taskMode", "", "afterTask", "(I)V", "beforeTask", "Lkotlinx/coroutines/scheduling/Task;", TimeSwitchSQLHelper.TABLE_TASK, "executeTask", "(Lkotlinx/coroutines/scheduling/Task;)V", "", "scanLocalQueue", "findAnyTask", "(Z)Lkotlinx/coroutines/scheduling/Task;", "findTask", "mode", "idleReset", "inStack", "()Z", "upperBound", "nextInt", "(I)I", "park", "()V", "pollGlobalQueues", "()Lkotlinx/coroutines/scheduling/Task;", "run", "runWorker", "tryAcquireCpuPermit", "tryPark", "Lkotlinx/coroutines/scheduling/CoroutineScheduler$WorkerState;", "newState", "tryReleaseCpu", "(Lkotlinx/coroutines/scheduling/CoroutineScheduler$WorkerState;)Z", "blockingOnly", "trySteal", "tryTerminateWorker", "indexInArray", "I", "getIndexInArray", "()I", "setIndexInArray", "Lkotlinx/coroutines/scheduling/WorkQueue;", "localQueue", "Lkotlinx/coroutines/scheduling/WorkQueue;", "mayHaveLocalTasks", "Z", "", "minDelayUntilStealableTaskNs", "J", "", "nextParkedWorker", "Ljava/lang/Object;", "getNextParkedWorker", "()Ljava/lang/Object;", "setNextParkedWorker", "(Ljava/lang/Object;)V", "rngState", "Lkotlinx/coroutines/scheduling/CoroutineScheduler;", "getScheduler", "()Lkotlinx/coroutines/scheduling/CoroutineScheduler;", "scheduler", "state", "Lkotlinx/coroutines/scheduling/CoroutineScheduler$WorkerState;", "terminationDeadline", "kotlinx-coroutines-core", "Ljava/lang/Thread;"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class Worker extends Thread { static final /* synthetic */ AtomicIntegerFieldUpdater workerCtl$FU = AtomicIntegerFieldUpdater.newUpdater(Worker.class, "workerCtl"); private volatile int indexInArray; public final WorkQueue localQueue; public boolean mayHaveLocalTasks; private long minDelayUntilStealableTaskNs; private volatile Object nextParkedWorker; private int rngState; public WorkerState state; private long terminationDeadline; volatile /* synthetic */ int workerCtl; private Worker() { setDaemon(true); this.localQueue = new WorkQueue(); this.state = WorkerState.DORMANT; this.workerCtl = 0; this.nextParkedWorker = CoroutineScheduler.NOT_IN_STACK; this.rngState = Random.INSTANCE.nextInt(); } public final int getIndexInArray() { return this.indexInArray; } public final void setIndexInArray(int i) { setName(CoroutineScheduler.this.schedulerName + "-worker-" + (i == 0 ? "TERMINATED" : String.valueOf(i))); this.indexInArray = i; } public Worker(CoroutineScheduler coroutineScheduler, int i) { this(); setIndexInArray(i); } public final CoroutineScheduler getScheduler() { return CoroutineScheduler.this; } public final Object getNextParkedWorker() { return this.nextParkedWorker; } public final void setNextParkedWorker(Object obj) { this.nextParkedWorker = obj; } private final boolean tryAcquireCpuPermit() { long j; if (this.state == WorkerState.CPU_ACQUIRED) { return true; } CoroutineScheduler coroutineScheduler = CoroutineScheduler.this; do { j = coroutineScheduler.controlState; if (((int) ((CoroutineScheduler.CPU_PERMITS_MASK & j) >> 42)) == 0) { return false; } } while (!CoroutineScheduler.controlState$FU.compareAndSet(coroutineScheduler, j, j - 4398046511104L)); this.state = WorkerState.CPU_ACQUIRED; return true; } public final boolean tryReleaseCpu(WorkerState newState) { WorkerState workerState = this.state; boolean z = workerState == WorkerState.CPU_ACQUIRED; if (z) { CoroutineScheduler.controlState$FU.addAndGet(CoroutineScheduler.this, 4398046511104L); } if (workerState != newState) { this.state = newState; } return z; } @Override // java.lang.Thread, java.lang.Runnable public void run() { runWorker(); } private final void runWorker() { loop0: while (true) { boolean z = false; while (!CoroutineScheduler.this.isTerminated() && this.state != WorkerState.TERMINATED) { Task taskFindTask = findTask(this.mayHaveLocalTasks); if (taskFindTask != null) { this.minDelayUntilStealableTaskNs = 0L; executeTask(taskFindTask); } else { this.mayHaveLocalTasks = false; if (this.minDelayUntilStealableTaskNs == 0) { tryPark(); } else if (z) { tryReleaseCpu(WorkerState.PARKING); Thread.interrupted(); LockSupport.parkNanos(this.minDelayUntilStealableTaskNs); this.minDelayUntilStealableTaskNs = 0L; } else { z = true; } } } break loop0; } tryReleaseCpu(WorkerState.TERMINATED); } private final void tryPark() { if (!inStack()) { CoroutineScheduler.this.parkedWorkersStackPush(this); return; } if (DebugKt.getASSERTIONS_ENABLED() && this.localQueue.getSize$kotlinx_coroutines_core() != 0) { throw new AssertionError(); } this.workerCtl = -1; while (inStack() && this.workerCtl == -1 && !CoroutineScheduler.this.isTerminated() && this.state != WorkerState.TERMINATED) { tryReleaseCpu(WorkerState.PARKING); Thread.interrupted(); park(); } } private final boolean inStack() { return this.nextParkedWorker != CoroutineScheduler.NOT_IN_STACK; } private final void beforeTask(int taskMode) { if (taskMode != 0 && tryReleaseCpu(WorkerState.BLOCKING)) { CoroutineScheduler.this.signalCpuWork(); } } private final void afterTask(int taskMode) { if (taskMode == 0) { return; } CoroutineScheduler.controlState$FU.addAndGet(CoroutineScheduler.this, CoroutineScheduler.PARKED_VERSION_MASK); WorkerState workerState = this.state; if (workerState != WorkerState.TERMINATED) { if (DebugKt.getASSERTIONS_ENABLED() && workerState != WorkerState.BLOCKING) { throw new AssertionError(); } this.state = WorkerState.DORMANT; } } public final int nextInt(int upperBound) { int i = this.rngState; int i2 = i ^ (i << 13); int i3 = i2 ^ (i2 >> 17); int i4 = i3 ^ (i3 << 5); this.rngState = i4; int i5 = upperBound - 1; return (i5 & upperBound) == 0 ? i5 & i4 : (Integer.MAX_VALUE & i4) % upperBound; } private final void park() { if (this.terminationDeadline == 0) { this.terminationDeadline = System.nanoTime() + CoroutineScheduler.this.idleWorkerKeepAliveNs; } LockSupport.parkNanos(CoroutineScheduler.this.idleWorkerKeepAliveNs); if (System.nanoTime() - this.terminationDeadline >= 0) { this.terminationDeadline = 0L; tryTerminateWorker(); } } private final void tryTerminateWorker() { ResizableAtomicArray resizableAtomicArray = CoroutineScheduler.this.workers; CoroutineScheduler coroutineScheduler = CoroutineScheduler.this; synchronized (resizableAtomicArray) { if (coroutineScheduler.isTerminated()) { return; } if (((int) (coroutineScheduler.controlState & 2097151)) <= coroutineScheduler.corePoolSize) { return; } if (workerCtl$FU.compareAndSet(this, -1, 1)) { int i = this.indexInArray; setIndexInArray(0); coroutineScheduler.parkedWorkersStackTopUpdate(this, i, 0); int andDecrement = (int) (CoroutineScheduler.controlState$FU.getAndDecrement(coroutineScheduler) & 2097151); if (andDecrement != i) { Worker worker = coroutineScheduler.workers.get(andDecrement); Intrinsics.checkNotNull(worker); Worker worker2 = worker; coroutineScheduler.workers.setSynchronized(i, worker2); worker2.setIndexInArray(i); coroutineScheduler.parkedWorkersStackTopUpdate(worker2, andDecrement, i); } coroutineScheduler.workers.setSynchronized(andDecrement, null); Unit unit = Unit.INSTANCE; this.state = WorkerState.TERMINATED; } } } private final void idleReset(int mode) { this.terminationDeadline = 0L; if (this.state == WorkerState.PARKING) { if (DebugKt.getASSERTIONS_ENABLED() && mode != 1) { throw new AssertionError(); } this.state = WorkerState.BLOCKING; } } public final Task findTask(boolean scanLocalQueue) { Task taskRemoveFirstOrNull; if (tryAcquireCpuPermit()) { return findAnyTask(scanLocalQueue); } if (!scanLocalQueue || (taskRemoveFirstOrNull = this.localQueue.poll()) == null) { taskRemoveFirstOrNull = CoroutineScheduler.this.globalBlockingQueue.removeFirstOrNull(); } return taskRemoveFirstOrNull == null ? trySteal(true) : taskRemoveFirstOrNull; } private final Task findAnyTask(boolean scanLocalQueue) { Task taskPollGlobalQueues; Task taskPollGlobalQueues2; if (scanLocalQueue) { boolean z = nextInt(CoroutineScheduler.this.corePoolSize * 2) == 0; if (z && (taskPollGlobalQueues2 = pollGlobalQueues()) != null) { return taskPollGlobalQueues2; } Task taskPoll = this.localQueue.poll(); if (taskPoll != null) { return taskPoll; } if (!z && (taskPollGlobalQueues = pollGlobalQueues()) != null) { return taskPollGlobalQueues; } } else { Task taskPollGlobalQueues3 = pollGlobalQueues(); if (taskPollGlobalQueues3 != null) { return taskPollGlobalQueues3; } } return trySteal(false); } private final Task pollGlobalQueues() { if (nextInt(2) == 0) { Task taskRemoveFirstOrNull = CoroutineScheduler.this.globalCpuQueue.removeFirstOrNull(); return taskRemoveFirstOrNull != null ? taskRemoveFirstOrNull : CoroutineScheduler.this.globalBlockingQueue.removeFirstOrNull(); } Task taskRemoveFirstOrNull2 = CoroutineScheduler.this.globalBlockingQueue.removeFirstOrNull(); return taskRemoveFirstOrNull2 != null ? taskRemoveFirstOrNull2 : CoroutineScheduler.this.globalCpuQueue.removeFirstOrNull(); } private final Task trySteal(boolean blockingOnly) { long jTryStealFrom; if (DebugKt.getASSERTIONS_ENABLED() && this.localQueue.getSize$kotlinx_coroutines_core() != 0) { throw new AssertionError(); } int i = (int) (CoroutineScheduler.this.controlState & 2097151); if (i < 2) { return null; } int iNextInt = nextInt(i); CoroutineScheduler coroutineScheduler = CoroutineScheduler.this; long jMin = Long.MAX_VALUE; for (int i2 = 0; i2 < i; i2++) { iNextInt++; if (iNextInt > i) { iNextInt = 1; } Worker worker = coroutineScheduler.workers.get(iNextInt); if (worker != null && worker != this) { if (DebugKt.getASSERTIONS_ENABLED() && this.localQueue.getSize$kotlinx_coroutines_core() != 0) { throw new AssertionError(); } if (blockingOnly) { jTryStealFrom = this.localQueue.tryStealBlockingFrom(worker.localQueue); } else { jTryStealFrom = this.localQueue.tryStealFrom(worker.localQueue); } if (jTryStealFrom == -1) { return this.localQueue.poll(); } if (jTryStealFrom > 0) { jMin = Math.min(jMin, jTryStealFrom); } } } if (jMin == LongCompanionObject.MAX_VALUE) { jMin = 0; } this.minDelayUntilStealableTaskNs = jMin; return null; } private final void executeTask(Task task) { int taskMode = task.taskContext.getTaskMode(); idleReset(taskMode); beforeTask(taskMode); CoroutineScheduler.this.runSafely(task); afterTask(taskMode); } } private final boolean addToGlobalQueue(Task task) { if (task.taskContext.getTaskMode() == 1) { return this.globalBlockingQueue.addLast(task); } return this.globalCpuQueue.addLast(task); } public final void parkedWorkersStackTopUpdate(Worker worker, int oldIndex, int newIndex) { while (true) { long j = this.parkedWorkersStack; int iParkedWorkersStackNextIndex = (int) (2097151 & j); long j2 = (PARKED_VERSION_INC + j) & PARKED_VERSION_MASK; if (iParkedWorkersStackNextIndex == oldIndex) { iParkedWorkersStackNextIndex = newIndex == 0 ? parkedWorkersStackNextIndex(worker) : newIndex; } if (iParkedWorkersStackNextIndex >= 0 && parkedWorkersStack$FU.compareAndSet(this, j, j2 | ((long) iParkedWorkersStackNextIndex))) { return; } } } private final Worker parkedWorkersStackPop() { while (true) { long j = this.parkedWorkersStack; Worker worker = this.workers.get((int) (2097151 & j)); if (worker == null) { return null; } long j2 = (PARKED_VERSION_INC + j) & PARKED_VERSION_MASK; int iParkedWorkersStackNextIndex = parkedWorkersStackNextIndex(worker); if (iParkedWorkersStackNextIndex >= 0 && parkedWorkersStack$FU.compareAndSet(this, j, ((long) iParkedWorkersStackNextIndex) | j2)) { worker.setNextParkedWorker(NOT_IN_STACK); return worker; } } } private final boolean tryAcquireCpuPermit() { long j; do { j = this.controlState; if (((int) ((CPU_PERMITS_MASK & j) >> 42)) == 0) { return false; } } while (!controlState$FU.compareAndSet(this, j, j - 4398046511104L)); return true; } private final void signalBlockingWork(boolean skipUnpark) { long jAddAndGet = controlState$FU.addAndGet(this, PARKED_VERSION_INC); if (skipUnpark || tryUnpark() || tryCreateWorker(jAddAndGet)) { return; } tryUnpark(); } }