package f.a.w.g;

import f.a.o;
import java.util.Objects;
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 o extends f.a.o {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final o f4021b = new o();

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

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final c f4023e;

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

        public a(Runnable runnable, c cVar, long j2) {
            this.f4022b = runnable;
            this.f4023e = cVar;
            this.f4024f = j2;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f4023e.f4032g) {
                return;
            }
            long jA = this.f4023e.a(TimeUnit.MILLISECONDS);
            long j2 = this.f4024f;
            if (j2 > jA) {
                try {
                    Thread.sleep(j2 - jA);
                } catch (InterruptedException e2) {
                    Thread.currentThread().interrupt();
                    f.a.y.a.C0(e2);
                    return;
                }
            }
            if (this.f4023e.f4032g) {
                return;
            }
            this.f4022b.run();
        }
    }

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final int f4027f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public volatile boolean f4028g;

        public b(Runnable runnable, Long l2, int i2) {
            this.f4025b = runnable;
            this.f4026e = l2.longValue();
            this.f4027f = i2;
        }

        @Override // java.lang.Comparable
        public int compareTo(b bVar) {
            b bVar2 = bVar;
            long j2 = this.f4026e;
            long j3 = bVar2.f4026e;
            int i2 = 1;
            int i3 = j2 < j3 ? -1 : j2 > j3 ? 1 : 0;
            if (i3 != 0) {
                return i3;
            }
            int i4 = this.f4027f;
            int i5 = bVar2.f4027f;
            if (i4 < i5) {
                i2 = -1;
            } else if (i4 <= i5) {
                i2 = 0;
            }
            return i2;
        }
    }

    /* JADX INFO: compiled from: TrampolineScheduler.java */
    public static final class c extends o.c implements f.a.t.b {

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

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

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

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public volatile boolean f4032g;

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

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

            public a(b bVar) {
                this.f4033b = bVar;
            }

            @Override // java.lang.Runnable
            public void run() {
                this.f4033b.f4028g = true;
                c.this.f4029b.remove(this.f4033b);
            }
        }

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

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

        @Override // f.a.t.b
        public void dispose() {
            this.f4032g = true;
        }

        public f.a.t.b e(Runnable runnable, long j2) {
            if (this.f4032g) {
                return f.a.w.a.c.INSTANCE;
            }
            b bVar = new b(runnable, Long.valueOf(j2), this.f4031f.incrementAndGet());
            this.f4029b.add(bVar);
            if (this.f4030e.getAndIncrement() != 0) {
                return new f.a.t.c(new a(bVar));
            }
            int iAddAndGet = 1;
            while (!this.f4032g) {
                b bVarPoll = this.f4029b.poll();
                if (bVarPoll == null) {
                    iAddAndGet = this.f4030e.addAndGet(-iAddAndGet);
                    if (iAddAndGet == 0) {
                        return f.a.w.a.c.INSTANCE;
                    }
                } else if (!bVarPoll.f4028g) {
                    bVarPoll.f4025b.run();
                }
            }
            this.f4029b.clear();
            return f.a.w.a.c.INSTANCE;
        }
    }

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

    @Override // f.a.o
    public f.a.t.b b(Runnable runnable) {
        runnable.run();
        return f.a.w.a.c.INSTANCE;
    }

    @Override // f.a.o
    public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        try {
            timeUnit.sleep(j2);
            Objects.requireNonNull(runnable, "run is null");
            runnable.run();
        } catch (InterruptedException e2) {
            Thread.currentThread().interrupt();
            f.a.y.a.C0(e2);
        }
        return f.a.w.a.c.INSTANCE;
    }
}