package V4;

import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/* JADX INFO: renamed from: V4.a0, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public final class C0749a0 extends Z implements J {

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

    public C0749a0(Executor executor) {
        this.f8280b = executor;
        if (executor instanceof ScheduledThreadPoolExecutor) {
            ((ScheduledThreadPoolExecutor) executor).setRemoveOnCancelPolicy(true);
        }
    }

    @Override // V4.J
    public final void a(long j4, C0772m c0772m) {
        Executor executor = this.f8280b;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule(new C1.a(9, this, c0772m), j4, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e6) {
                E.h(c0772m.f8316e, E.a("The task was rejected", e6));
            }
        }
        if (scheduledFutureSchedule != null) {
            c0772m.v(new C0766j(scheduledFutureSchedule, 0));
        } else {
            F.l.a(j4, c0772m);
        }
    }

    @Override // V4.J
    public final P b(long j4, I0 i02, A4.j jVar) {
        Executor executor = this.f8280b;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule(i02, j4, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e6) {
                E.h(jVar, E.a("The task was rejected", e6));
            }
        }
        return scheduledFutureSchedule != null ? new O(scheduledFutureSchedule) : F.l.b(j4, i02, jVar);
    }

    @Override // V4.AbstractC0786y
    public final void c(A4.j jVar, Runnable runnable) {
        try {
            this.f8280b.execute(runnable);
        } catch (RejectedExecutionException e6) {
            E.h(jVar, E.a("The task was rejected", e6));
            c5.e eVar = N.f8259a;
            c5.d.f13466b.c(jVar, runnable);
        }
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        Executor executor = this.f8280b;
        ExecutorService executorService = executor instanceof ExecutorService ? (ExecutorService) executor : null;
        if (executorService != null) {
            executorService.shutdown();
        }
    }

    public final boolean equals(Object obj) {
        return (obj instanceof C0749a0) && ((C0749a0) obj).f8280b == this.f8280b;
    }

    public final int hashCode() {
        return System.identityHashCode(this.f8280b);
    }

    @Override // V4.AbstractC0786y
    public final String toString() {
        return this.f8280b.toString();
    }
}