package g.a;

import g.a.c1;
import java.util.concurrent.locks.LockSupport;

/* JADX INFO: compiled from: EventLoop.kt */
/* JADX INFO: loaded from: classes.dex */
public abstract class d1 extends b1 {
    protected abstract Thread Q();

    protected void R(long j2, c1.b bVar) {
        n0.f4053k.l0(j2, bVar);
    }

    protected final void S() {
        f.t tVar;
        Thread threadQ = Q();
        if (Thread.currentThread() != threadQ) {
            b bVarA = c.a();
            if (bVarA != null) {
                bVarA.f(threadQ);
                tVar = f.t.a;
            } else {
                tVar = null;
            }
            if (tVar == null) {
                LockSupport.unpark(threadQ);
            }
        }
    }
}