package e.a.u.g;

import e.a.n;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: compiled from: TrampolineScheduler.java */
/* JADX INFO: loaded from: classes.dex */
public final class l extends n {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private static final l f3842b = new l();

    /* JADX INFO: compiled from: TrampolineScheduler.java */
    static final class a implements Runnable {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        private final Runnable f3843b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        private final c f3844f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        private final long f3845g;

        a(Runnable runnable, c cVar, long j2) {
            this.f3843b = runnable;
            this.f3844f = cVar;
            this.f3845g = j2;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f3844f.f3853h) {
                return;
            }
            long jA = this.f3844f.a(TimeUnit.MILLISECONDS);
            long j2 = this.f3845g;
            if (j2 > jA) {
                long j3 = j2 - jA;
                if (j3 > 0) {
                    try {
                        Thread.sleep(j3);
                    } catch (InterruptedException e2) {
                        Thread.currentThread().interrupt();
                        e.a.w.a.p(e2);
                        return;
                    }
                }
            }
            if (this.f3844f.f3853h) {
                return;
            }
            this.f3843b.run();
        }
    }

    /* JADX INFO: compiled from: TrampolineScheduler.java */
    static final class b implements Comparable<b> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final Runnable f3846b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final long f3847f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final int f3848g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        volatile boolean f3849h;

        b(Runnable runnable, Long l, int i2) {
            this.f3846b = runnable;
            this.f3847f = l.longValue();
            this.f3848g = i2;
        }

        @Override // java.lang.Comparable
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public int compareTo(b bVar) {
            int iB = e.a.u.b.b.b(this.f3847f, bVar.f3847f);
            return iB == 0 ? e.a.u.b.b.a(this.f3848g, bVar.f3848g) : iB;
        }
    }

    /* JADX INFO: compiled from: TrampolineScheduler.java */
    static final class c extends n.c implements e.a.r.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final PriorityBlockingQueue<b> f3850b = new PriorityBlockingQueue<>();

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        private final AtomicInteger f3851f = new AtomicInteger();

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final AtomicInteger f3852g = new AtomicInteger();

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        volatile boolean f3853h;

        /* JADX INFO: compiled from: TrampolineScheduler.java */
        final class a implements Runnable {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            final b f3854b;

            a(b bVar) {
                this.f3854b = bVar;
            }

            @Override // java.lang.Runnable
            public void run() {
                this.f3854b.f3849h = true;
                c.this.f3850b.remove(this.f3854b);
            }
        }

        c() {
        }

        @Override // e.a.n.c
        public e.a.r.b b(Runnable runnable) {
            return e(runnable, a(TimeUnit.MILLISECONDS));
        }

        @Override // e.a.n.c
        public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            long jA = a(TimeUnit.MILLISECONDS) + timeUnit.toMillis(j2);
            return e(new a(runnable, this, jA), jA);
        }

        @Override // e.a.r.b
        public void dispose() {
            this.f3853h = true;
        }

        e.a.r.b e(Runnable runnable, long j2) {
            if (this.f3853h) {
                return e.a.u.a.c.INSTANCE;
            }
            b bVar = new b(runnable, Long.valueOf(j2), this.f3852g.incrementAndGet());
            this.f3850b.add(bVar);
            if (this.f3851f.getAndIncrement() != 0) {
                return e.a.r.c.b(new a(bVar));
            }
            int iAddAndGet = 1;
            while (true) {
                b bVarPoll = this.f3850b.poll();
                if (bVarPoll == null) {
                    iAddAndGet = this.f3851f.addAndGet(-iAddAndGet);
                    if (iAddAndGet == 0) {
                        return e.a.u.a.c.INSTANCE;
                    }
                } else if (!bVarPoll.f3849h) {
                    bVarPoll.f3846b.run();
                }
            }
        }

        @Override // e.a.r.b
        public boolean isDisposed() {
            return this.f3853h;
        }
    }

    l() {
    }

    public static l e() {
        return f3842b;
    }

    @Override // e.a.n
    public n.c a() {
        return new c();
    }

    @Override // e.a.n
    public e.a.r.b b(Runnable runnable) {
        runnable.run();
        return e.a.u.a.c.INSTANCE;
    }

    @Override // e.a.n
    public e.a.r.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        try {
            timeUnit.sleep(j2);
            runnable.run();
        } catch (InterruptedException e2) {
            Thread.currentThread().interrupt();
            e.a.w.a.p(e2);
        }
        return e.a.u.a.c.INSTANCE;
    }
}