package o.a.h.g;

import java.util.Objects;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import o.a.d;

/* JADX INFO: loaded from: classes.dex */
public final class d extends o.a.d {

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final g f6051c;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final c f6054f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public static final a f6055g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final ThreadFactory f6056h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final AtomicReference<a> f6057i;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public static final TimeUnit f6053e = TimeUnit.SECONDS;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static final long f6052d = Long.getLong("rx2.io-keep-alive-time", 60).longValue();

    public static final class a implements Runnable {

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

        /* JADX INFO: renamed from: m, reason: collision with root package name */
        public final ConcurrentLinkedQueue<c> f6059m;

        /* JADX INFO: renamed from: n, reason: collision with root package name */
        public final o.a.e.a f6060n;

        /* JADX INFO: renamed from: o, reason: collision with root package name */
        public final ScheduledExecutorService f6061o;

        /* JADX INFO: renamed from: p, reason: collision with root package name */
        public final Future<?> f6062p;

        /* JADX INFO: renamed from: q, reason: collision with root package name */
        public final ThreadFactory f6063q;

        public a(long j2, TimeUnit timeUnit, ThreadFactory threadFactory) {
            ScheduledFuture<?> scheduledFutureScheduleWithFixedDelay;
            long nanos = timeUnit != null ? timeUnit.toNanos(j2) : 0L;
            this.f6058f = nanos;
            this.f6059m = new ConcurrentLinkedQueue<>();
            this.f6060n = new o.a.e.a();
            this.f6063q = threadFactory;
            ScheduledExecutorService scheduledExecutorServiceNewScheduledThreadPool = null;
            if (timeUnit != null) {
                scheduledExecutorServiceNewScheduledThreadPool = Executors.newScheduledThreadPool(1, d.f6051c);
                scheduledFutureScheduleWithFixedDelay = scheduledExecutorServiceNewScheduledThreadPool.scheduleWithFixedDelay(this, nanos, nanos, TimeUnit.NANOSECONDS);
            } else {
                scheduledFutureScheduleWithFixedDelay = null;
            }
            this.f6061o = scheduledExecutorServiceNewScheduledThreadPool;
            this.f6062p = scheduledFutureScheduleWithFixedDelay;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f6059m.isEmpty()) {
                return;
            }
            long jNanoTime = System.nanoTime();
            for (c cVar : this.f6059m) {
                if (cVar.f6068n > jNanoTime) {
                    return;
                }
                if (this.f6059m.remove(cVar) && this.f6060n.d(cVar)) {
                    cVar.b();
                }
            }
        }
    }

    public static final class b extends d.c {

        /* JADX INFO: renamed from: m, reason: collision with root package name */
        public final a f6065m;

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final o.a.e.a f6064f = new o.a.e.a();

        public b(a aVar) {
            c cVar;
            c cVar2;
            this.f6065m = aVar;
            if (aVar.f6060n.f5962m) {
                cVar2 = d.f6054f;
            } else {
                while (true) {
                    if (aVar.f6059m.isEmpty()) {
                        cVar = new c(aVar.f6063q);
                        aVar.f6060n.c(cVar);
                        break;
                    } else {
                        cVar = aVar.f6059m.poll();
                        if (cVar != null) {
                            break;
                        }
                    }
                }
                cVar2 = cVar;
            }
            this.f6066n = cVar2;
        }

        @Override // o.a.e.b
        public void b() {
            if (this.f6067o.compareAndSet(false, true)) {
                this.f6064f.b();
                a aVar = this.f6065m;
                c cVar = this.f6066n;
                Objects.requireNonNull(aVar);
                cVar.f6068n = System.nanoTime() + aVar.f6058f;
                aVar.f6059m.offer(cVar);
            }
        }

        @Override // o.a.d.c
        public o.a.e.b d(Runnable runnable, long j2, TimeUnit timeUnit) {
            return this.f6064f.f5962m ? o.a.h.a.c.INSTANCE : this.f6066n.g(runnable, j2, timeUnit, this.f6064f);
        }
    }

    public static final class c extends f {

        /* JADX INFO: renamed from: n, reason: collision with root package name */
        public long f6068n;

        public c(ThreadFactory threadFactory) {
            super(threadFactory);
            this.f6068n = 0L;
        }
    }

    static {
        c cVar = new c(new g("RxCachedThreadSchedulerShutdown"));
        f6054f = cVar;
        cVar.b();
        int iMax = Math.max(1, Math.min(10, Integer.getInteger("rx2.io-priority", 5).intValue()));
        g gVar = new g("RxCachedThreadScheduler", iMax);
        f6050b = gVar;
        f6051c = new g("RxCachedWorkerPoolEvictor", iMax);
        a aVar = new a(0L, null, gVar);
        f6055g = aVar;
        aVar.f6060n.b();
        Future<?> future = aVar.f6062p;
        if (future != null) {
            future.cancel(true);
        }
        ScheduledExecutorService scheduledExecutorService = aVar.f6061o;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.shutdownNow();
        }
    }

    public d() {
        g gVar = f6050b;
        this.f6056h = gVar;
        a aVar = f6055g;
        AtomicReference<a> atomicReference = new AtomicReference<>(aVar);
        this.f6057i = atomicReference;
        a aVar2 = new a(f6052d, f6053e, gVar);
        if (atomicReference.compareAndSet(aVar, aVar2)) {
            return;
        }
        aVar2.f6060n.b();
        Future<?> future = aVar2.f6062p;
        if (future != null) {
            future.cancel(true);
        }
        ScheduledExecutorService scheduledExecutorService = aVar2.f6061o;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.shutdownNow();
        }
    }

    @Override // o.a.d
    public d.c a() {
        return new b(this.f6057i.get());
    }
}