package p025.p026;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
import p025.p026.AbstractC1346;
import p402.p417.C6664;

/* JADX INFO: renamed from: އ.֏.ޙ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public final class RunnableC1330 extends AbstractC1346 implements Runnable {
    public static volatile Thread _thread;
    public static volatile int debugStatus;

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public static final long f4470;

    /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
    public static final RunnableC1330 f4471;

    static {
        Long l;
        RunnableC1330 runnableC1330 = new RunnableC1330();
        f4471 = runnableC1330;
        runnableC1330.m2672(false);
        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
        try {
            l = Long.getLong("kotlinx.coroutines.DefaultExecutor.keepAlive", 1000L);
        } catch (SecurityException unused) {
            l = 1000L;
        }
        f4470 = timeUnit.toNanos(l.longValue());
    }

    @Override // java.lang.Runnable
    public void run() {
        boolean zM2678;
        C1385 c1385 = C1385.f4539;
        C1385.f4538.set(this);
        try {
            if (!m2659()) {
                if (zM2678) {
                    return;
                } else {
                    return;
                }
            }
            long j = Long.MAX_VALUE;
            while (true) {
                Thread.interrupted();
                long jM2679 = m2679();
                if (jM2679 == Long.MAX_VALUE) {
                    long jNanoTime = System.nanoTime();
                    if (j == Long.MAX_VALUE) {
                        j = f4470 + jNanoTime;
                    }
                    long j2 = j - jNanoTime;
                    if (j2 <= 0) {
                        _thread = null;
                        m2656();
                        if (m2678()) {
                            return;
                        }
                        mo2618();
                        return;
                    }
                    jM2679 = C6664.m9843(jM2679, j2);
                } else {
                    j = Long.MAX_VALUE;
                }
                if (jM2679 > 0) {
                    if (m2658()) {
                        _thread = null;
                        m2656();
                        if (m2678()) {
                            return;
                        }
                        mo2618();
                        return;
                    }
                    LockSupport.parkNanos(this, jM2679);
                }
            }
        } finally {
            _thread = null;
            m2656();
            if (!m2678()) {
                mo2618();
            }
        }
    }

    @Override // p025.p026.AbstractC1346, p025.p026.InterfaceC1335
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public InterfaceC1341 mo2655(long j, Runnable runnable) {
        long jM2681 = C1352.m2681(j);
        if (jM2681 >= 4611686018427387903L) {
            return C1378.f4536;
        }
        long jNanoTime = System.nanoTime();
        AbstractC1346.C1348 c1348 = new AbstractC1346.C1348(jM2681 + jNanoTime, runnable);
        m2675(jNanoTime, (AbstractC1346.AbstractRunnableC1349) c1348);
        return c1348;
    }

    @Override // p025.p026.AbstractC1351
    /* JADX INFO: renamed from: ފ */
    public Thread mo2618() {
        Thread thread = _thread;
        return thread != null ? thread : m2657();
    }

    /* JADX INFO: renamed from: ޒ, reason: contains not printable characters */
    public final synchronized void m2656() {
        if (m2658()) {
            debugStatus = 3;
            this._queue = null;
            this._delayed = null;
            notifyAll();
        }
    }

    /* JADX INFO: renamed from: ޓ, reason: contains not printable characters */
    public final synchronized Thread m2657() {
        Thread thread;
        thread = _thread;
        if (thread == null) {
            thread = new Thread(this, "kotlinx.coroutines.DefaultExecutor");
            _thread = thread;
            thread.setDaemon(true);
            thread.start();
        }
        return thread;
    }

    /* JADX INFO: renamed from: ޔ, reason: contains not printable characters */
    public final boolean m2658() {
        int i = debugStatus;
        return i == 2 || i == 3;
    }

    /* JADX INFO: renamed from: ޕ, reason: contains not printable characters */
    public final synchronized boolean m2659() {
        if (m2658()) {
            return false;
        }
        debugStatus = 1;
        notifyAll();
        return true;
    }
}