package f.a.w.g;

import f.a.o;
import java.util.Objects;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final f.a.o f3956b = f.a.z.a.a;

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

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

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

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

        @Override // java.lang.Runnable
        public void run() {
            b bVar = this.f3958b;
            f.a.w.a.f fVar = bVar.f3961e;
            f.a.t.b bVarB = d.this.b(bVar);
            Objects.requireNonNull(fVar);
            f.a.w.a.b.replace(fVar, bVarB);
        }
    }

    /* JADX INFO: compiled from: ExecutorScheduler.java */
    public static final class b extends AtomicReference<Runnable> implements Runnable, f.a.t.b {

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

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

        public b(Runnable runnable) {
            super(runnable);
            this.f3960b = new f.a.w.a.f();
            this.f3961e = new f.a.w.a.f();
        }

        @Override // f.a.t.b
        public void dispose() {
            if (getAndSet(null) != null) {
                f.a.w.a.f fVar = this.f3960b;
                Objects.requireNonNull(fVar);
                f.a.w.a.b.dispose(fVar);
                f.a.w.a.f fVar2 = this.f3961e;
                Objects.requireNonNull(fVar2);
                f.a.w.a.b.dispose(fVar2);
            }
        }

        @Override // java.lang.Runnable
        public void run() {
            Runnable runnable = get();
            if (runnable != null) {
                try {
                    runnable.run();
                    lazySet(null);
                    f.a.w.a.f fVar = this.f3960b;
                    f.a.w.a.b bVar = f.a.w.a.b.DISPOSED;
                    fVar.lazySet(bVar);
                    this.f3961e.lazySet(bVar);
                } catch (Throwable th) {
                    lazySet(null);
                    this.f3960b.lazySet(f.a.w.a.b.DISPOSED);
                    this.f3961e.lazySet(f.a.w.a.b.DISPOSED);
                    throw th;
                }
            }
        }
    }

    /* JADX INFO: compiled from: ExecutorScheduler.java */
    public static final class c extends o.c implements Runnable {

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

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final f.a.w.f.a<Runnable> f3964f = new f.a.w.f.a<>();

        /* JADX INFO: compiled from: ExecutorScheduler.java */
        public static final class a extends AtomicBoolean implements Runnable, f.a.t.b {

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

            public a(Runnable runnable) {
                this.f3968b = runnable;
            }

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

            @Override // java.lang.Runnable
            public void run() {
                if (get()) {
                    return;
                }
                try {
                    this.f3968b.run();
                } finally {
                    lazySet(true);
                }
            }
        }

        /* JADX INFO: compiled from: ExecutorScheduler.java */
        public static final class b extends AtomicInteger implements Runnable, f.a.t.b {

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

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

            /* JADX INFO: renamed from: f, reason: collision with root package name */
            public volatile Thread f3971f;

            public b(Runnable runnable, f.a.w.a.a aVar) {
                this.f3969b = runnable;
                this.f3970e = aVar;
            }

            public void a() {
                f.a.w.a.a aVar = this.f3970e;
                if (aVar != null) {
                    aVar.c(this);
                }
            }

            @Override // f.a.t.b
            public void dispose() {
                while (true) {
                    int i2 = get();
                    if (i2 >= 2) {
                        return;
                    }
                    if (i2 == 0) {
                        if (compareAndSet(0, 4)) {
                            a();
                            return;
                        }
                    } else if (compareAndSet(1, 3)) {
                        Thread thread = this.f3971f;
                        if (thread != null) {
                            thread.interrupt();
                            this.f3971f = null;
                        }
                        set(4);
                        a();
                        return;
                    }
                }
            }

            @Override // java.lang.Runnable
            public void run() {
                if (get() == 0) {
                    this.f3971f = Thread.currentThread();
                    if (!compareAndSet(0, 1)) {
                        this.f3971f = null;
                        return;
                    }
                    try {
                        this.f3969b.run();
                        this.f3971f = null;
                        if (compareAndSet(1, 2)) {
                            a();
                            return;
                        }
                        while (get() == 3) {
                            Thread.yield();
                        }
                        Thread.interrupted();
                    } catch (Throwable th) {
                        this.f3971f = null;
                        if (compareAndSet(1, 2)) {
                            a();
                        } else {
                            while (get() == 3) {
                                Thread.yield();
                            }
                            Thread.interrupted();
                        }
                        throw th;
                    }
                }
            }
        }

        /* JADX INFO: renamed from: f.a.w.g.d$c$c, reason: collision with other inner class name */
        /* JADX INFO: compiled from: ExecutorScheduler.java */
        public final class RunnableC0072c implements Runnable {

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

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

            public RunnableC0072c(f.a.w.a.f fVar, Runnable runnable) {
                this.f3972b = fVar;
                this.f3973e = runnable;
            }

            @Override // java.lang.Runnable
            public void run() {
                f.a.w.a.f fVar = this.f3972b;
                f.a.t.b bVarB = c.this.b(this.f3973e);
                Objects.requireNonNull(fVar);
                f.a.w.a.b.replace(fVar, bVarB);
            }
        }

        public c(Executor executor, boolean z) {
            this.f3963e = executor;
            this.f3962b = z;
        }

        @Override // f.a.o.c
        public f.a.t.b b(Runnable runnable) {
            f.a.t.b aVar;
            if (this.f3965g) {
                return f.a.w.a.c.INSTANCE;
            }
            Objects.requireNonNull(runnable, "run is null");
            if (this.f3962b) {
                aVar = new b(runnable, this.f3967i);
                this.f3967i.b(aVar);
            } else {
                aVar = new a(runnable);
            }
            this.f3964f.offer(aVar);
            if (this.f3966h.getAndIncrement() == 0) {
                try {
                    this.f3963e.execute(this);
                } catch (RejectedExecutionException e2) {
                    this.f3965g = true;
                    this.f3964f.clear();
                    f.a.y.a.C0(e2);
                    return f.a.w.a.c.INSTANCE;
                }
            }
            return aVar;
        }

        @Override // f.a.o.c
        public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
            if (j2 <= 0) {
                return b(runnable);
            }
            if (this.f3965g) {
                return f.a.w.a.c.INSTANCE;
            }
            f.a.w.a.f fVar = new f.a.w.a.f();
            f.a.w.a.f fVar2 = new f.a.w.a.f(fVar);
            Objects.requireNonNull(runnable, "run is null");
            l lVar = new l(new RunnableC0072c(fVar2, runnable), this.f3967i);
            this.f3967i.b(lVar);
            Executor executor = this.f3963e;
            if (executor instanceof ScheduledExecutorService) {
                try {
                    lVar.a(((ScheduledExecutorService) executor).schedule((Callable) lVar, j2, timeUnit));
                } catch (RejectedExecutionException e2) {
                    this.f3965g = true;
                    f.a.y.a.C0(e2);
                    return f.a.w.a.c.INSTANCE;
                }
            } else {
                lVar.a(new f.a.w.g.c(d.f3956b.c(lVar, j2, timeUnit)));
            }
            f.a.w.a.b.replace(fVar, lVar);
            return fVar2;
        }

        @Override // f.a.t.b
        public void dispose() {
            if (this.f3965g) {
                return;
            }
            this.f3965g = true;
            this.f3967i.dispose();
            if (this.f3966h.getAndIncrement() == 0) {
                this.f3964f.clear();
            }
        }

        @Override // java.lang.Runnable
        public void run() {
            f.a.w.f.a<Runnable> aVar = this.f3964f;
            int iAddAndGet = 1;
            while (!this.f3965g) {
                do {
                    Runnable runnablePoll = aVar.poll();
                    if (runnablePoll != null) {
                        runnablePoll.run();
                    } else if (this.f3965g) {
                        aVar.clear();
                        return;
                    } else {
                        iAddAndGet = this.f3966h.addAndGet(-iAddAndGet);
                        if (iAddAndGet == 0) {
                            return;
                        }
                    }
                } while (!this.f3965g);
                aVar.clear();
                return;
            }
            aVar.clear();
        }
    }

    public d(Executor executor, boolean z) {
        this.f3957c = executor;
    }

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

    @Override // f.a.o
    public f.a.t.b b(Runnable runnable) {
        Objects.requireNonNull(runnable, "run is null");
        try {
            if (this.f3957c instanceof ExecutorService) {
                k kVar = new k(runnable);
                kVar.a(((ExecutorService) this.f3957c).submit(kVar));
                return kVar;
            }
            c.a aVar = new c.a(runnable);
            this.f3957c.execute(aVar);
            return aVar;
        } catch (RejectedExecutionException e2) {
            f.a.y.a.C0(e2);
            return f.a.w.a.c.INSTANCE;
        }
    }

    @Override // f.a.o
    public f.a.t.b c(Runnable runnable, long j2, TimeUnit timeUnit) {
        Objects.requireNonNull(runnable, "run is null");
        if (this.f3957c instanceof ScheduledExecutorService) {
            try {
                k kVar = new k(runnable);
                kVar.a(((ScheduledExecutorService) this.f3957c).schedule(kVar, j2, timeUnit));
                return kVar;
            } catch (RejectedExecutionException e2) {
                f.a.y.a.C0(e2);
                return f.a.w.a.c.INSTANCE;
            }
        }
        b bVar = new b(runnable);
        f.a.t.b bVarC = f3956b.c(new a(bVar), j2, timeUnit);
        f.a.w.a.f fVar = bVar.f3960b;
        Objects.requireNonNull(fVar);
        f.a.w.a.b.replace(fVar, bVarC);
        return bVar;
    }

    @Override // f.a.o
    public f.a.t.b d(Runnable runnable, long j2, long j3, TimeUnit timeUnit) {
        if (!(this.f3957c instanceof ScheduledExecutorService)) {
            return super.d(runnable, j2, j3, timeUnit);
        }
        try {
            j jVar = new j(runnable);
            jVar.a(((ScheduledExecutorService) this.f3957c).scheduleAtFixedRate(jVar, j2, j3, timeUnit));
            return jVar;
        } catch (RejectedExecutionException e2) {
            f.a.y.a.C0(e2);
            return f.a.w.a.c.INSTANCE;
        }
    }
}