package kotlinx.coroutines;

import java.util.concurrent.locks.LockSupport;
import kotlinx.coroutines.g1;

/* JADX INFO: compiled from: EventLoop.kt */
/* JADX INFO: loaded from: classes.dex */
public abstract class h1 extends f1 {
    protected abstract Thread c0();

    protected final void d0(long j2, g1.b bVar) {
        if (r0.a()) {
            if (!(this != t0.f1168k)) {
                throw new AssertionError();
            }
        }
        t0.f1168k.t0(j2, bVar);
    }

    protected final void g0() {
        Thread threadC0 = c0();
        if (Thread.currentThread() != threadC0) {
            d dVarA = e.a();
            if (dVarA == null) {
                LockSupport.unpark(threadC0);
            } else {
                dVarA.f(threadC0);
            }
        }
    }
}