package c.a.q.g;

import c.a.g;
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 n extends c.a.g {

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

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

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

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

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

        a(Runnable runnable, c cVar, long j) {
            this.f1882c = runnable;
            this.f1883d = cVar;
            this.f1884e = j;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f1883d.f1892f) {
                return;
            }
            long jA = this.f1883d.a(TimeUnit.MILLISECONDS);
            long j = this.f1884e;
            if (j > jA) {
                long j2 = j - jA;
                if (j2 > 0) {
                    try {
                        Thread.sleep(j2);
                    } catch (InterruptedException e2) {
                        Thread.currentThread().interrupt();
                        c.a.r.a.o(e2);
                        return;
                    }
                }
            }
            if (this.f1883d.f1892f) {
                return;
            }
            this.f1882c.run();
        }
    }

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

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

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

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

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

        b(Runnable runnable, Long l, int i) {
            this.f1885c = runnable;
            this.f1886d = l.longValue();
            this.f1887e = i;
        }

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

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

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

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

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

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

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

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

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

            @Override // java.lang.Runnable
            public void run() {
                this.f1893c.f1888f = true;
                c.this.f1889c.remove(this.f1893c);
            }
        }

        c() {
        }

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

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

        @Override // c.a.n.b
        public void dispose() {
            this.f1892f = true;
        }

        c.a.n.b e(Runnable runnable, long j) {
            if (this.f1892f) {
                return c.a.q.a.c.INSTANCE;
            }
            b bVar = new b(runnable, Long.valueOf(j), this.f1891e.incrementAndGet());
            this.f1889c.add(bVar);
            if (this.f1890d.getAndIncrement() != 0) {
                return c.a.n.c.b(new a(bVar));
            }
            int iAddAndGet = 1;
            while (!this.f1892f) {
                b bVarPoll = this.f1889c.poll();
                if (bVarPoll == null) {
                    iAddAndGet = this.f1890d.addAndGet(-iAddAndGet);
                    if (iAddAndGet == 0) {
                        return c.a.q.a.c.INSTANCE;
                    }
                } else if (!bVarPoll.f1888f) {
                    bVarPoll.f1885c.run();
                }
            }
            this.f1889c.clear();
            return c.a.q.a.c.INSTANCE;
        }
    }

    n() {
    }

    public static n e() {
        return f1881b;
    }

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

    @Override // c.a.g
    public c.a.n.b b(Runnable runnable) {
        runnable.run();
        return c.a.q.a.c.INSTANCE;
    }

    @Override // c.a.g
    public c.a.n.b c(Runnable runnable, long j, TimeUnit timeUnit) {
        try {
            timeUnit.sleep(j);
            runnable.run();
        } catch (InterruptedException e2) {
            Thread.currentThread().interrupt();
            c.a.r.a.o(e2);
        }
        return c.a.q.a.c.INSTANCE;
    }
}