package f.a.w.g;

import f.a.o;
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;

/* JADX INFO: compiled from: IoScheduler.java */
/* JADX INFO: loaded from: classes.dex */
public final class f extends f.a.o {

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

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

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

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

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

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

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final f.a.t.a f3991f;

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

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

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

        public a(long j2, TimeUnit timeUnit, ThreadFactory threadFactory) {
            ScheduledFuture<?> scheduledFutureScheduleWithFixedDelay;
            long nanos = timeUnit != null ? timeUnit.toNanos(j2) : 0L;
            this.f3989b = nanos;
            this.f3990e = new ConcurrentLinkedQueue<>();
            this.f3991f = new f.a.t.a();
            this.f3994i = threadFactory;
            ScheduledExecutorService scheduledExecutorServiceNewScheduledThreadPool = null;
            if (timeUnit != null) {
                scheduledExecutorServiceNewScheduledThreadPool = Executors.newScheduledThreadPool(1, f.f3982c);
                scheduledFutureScheduleWithFixedDelay = scheduledExecutorServiceNewScheduledThreadPool.scheduleWithFixedDelay(this, nanos, nanos, TimeUnit.NANOSECONDS);
            } else {
                scheduledFutureScheduleWithFixedDelay = null;
            }
            this.f3992g = scheduledExecutorServiceNewScheduledThreadPool;
            this.f3993h = scheduledFutureScheduleWithFixedDelay;
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f3990e.isEmpty()) {
                return;
            }
            long jNanoTime = System.nanoTime();
            for (c cVar : this.f3990e) {
                if (cVar.f3999f > jNanoTime) {
                    return;
                }
                if (this.f3990e.remove(cVar) && this.f3991f.c(cVar)) {
                    cVar.dispose();
                }
            }
        }
    }

    /* JADX INFO: compiled from: IoScheduler.java */
    public static final class b extends o.c {

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

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

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

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

        public b(a aVar) {
            c cVar;
            c cVar2;
            this.f3996e = aVar;
            if (aVar.f3991f.f3719e) {
                cVar2 = f.f3985f;
            } else {
                while (true) {
                    if (aVar.f3990e.isEmpty()) {
                        cVar = new c(aVar.f3994i);
                        aVar.f3991f.b(cVar);
                        break;
                    } else {
                        cVar = aVar.f3990e.poll();
                        if (cVar != null) {
                            break;
                        }
                    }
                }
                cVar2 = cVar;
            }
            this.f3997f = cVar2;
        }

        @Override // f.a.o.c
        public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            return this.f3995b.f3719e ? f.a.w.a.c.INSTANCE : this.f3997f.e(runnable, j2, timeUnit, this.f3995b);
        }

        @Override // f.a.t.b
        public void dispose() {
            if (this.f3998g.compareAndSet(false, true)) {
                this.f3995b.dispose();
                a aVar = this.f3996e;
                c cVar = this.f3997f;
                Objects.requireNonNull(aVar);
                cVar.f3999f = System.nanoTime() + aVar.f3989b;
                aVar.f3990e.offer(cVar);
            }
        }
    }

    /* JADX INFO: compiled from: IoScheduler.java */
    public static final class c extends h {

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

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

    static {
        c cVar = new c(new i("RxCachedThreadSchedulerShutdown"));
        f3985f = cVar;
        cVar.dispose();
        int iMax = Math.max(1, Math.min(10, Integer.getInteger("rx2.io-priority", 5).intValue()));
        i iVar = new i("RxCachedThreadScheduler", iMax);
        f3981b = iVar;
        f3982c = new i("RxCachedWorkerPoolEvictor", iMax);
        a aVar = new a(0L, null, iVar);
        f3986g = aVar;
        aVar.f3991f.dispose();
        Future<?> future = aVar.f3993h;
        if (future != null) {
            future.cancel(true);
        }
        ScheduledExecutorService scheduledExecutorService = aVar.f3992g;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.shutdownNow();
        }
    }

    public f() {
        i iVar = f3981b;
        this.f3987h = iVar;
        a aVar = f3986g;
        AtomicReference<a> atomicReference = new AtomicReference<>(aVar);
        this.f3988i = atomicReference;
        a aVar2 = new a(f3983d, f3984e, iVar);
        if (atomicReference.compareAndSet(aVar, aVar2)) {
            return;
        }
        aVar2.f3991f.dispose();
        Future<?> future = aVar2.f3993h;
        if (future != null) {
            future.cancel(true);
        }
        ScheduledExecutorService scheduledExecutorService = aVar2.f3992g;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.shutdownNow();
        }
    }

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