package Z6;

import java.util.concurrent.CancellationException;
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: loaded from: classes.dex */
public final class W extends V implements E {

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

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

    public static void n0(E6.i iVar, RejectedExecutionException rejectedExecutionException) {
        CancellationException cancellationException = new CancellationException("The task was rejected");
        cancellationException.initCause(rejectedExecutionException);
        AbstractC0385z.e(iVar, cancellationException);
    }

    @Override // Z6.E
    public final void H(long j8, C0369i c0369i) {
        Executor executor = this.f7492s;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule(new G3.b(this, 6, c0369i), j8, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e8) {
                n0(c0369i.f7517u, e8);
            }
        }
        if (scheduledFutureSchedule != null) {
            c0369i.y(new C0365e(0, scheduledFutureSchedule));
        } else {
            A.f7467z.H(j8, c0369i);
        }
    }

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

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

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

    @Override // Z6.AbstractC0378s
    public final void j0(E6.i iVar, Runnable runnable) {
        try {
            this.f7492s.execute(runnable);
        } catch (RejectedExecutionException e8) {
            n0(iVar, e8);
            g7.e eVar = J.f7474a;
            g7.d.f12985s.j0(iVar, runnable);
        }
    }

    @Override // Z6.V
    public final Executor m0() {
        return this.f7492s;
    }

    @Override // Z6.AbstractC0378s
    public final String toString() {
        return this.f7492s.toString();
    }

    @Override // Z6.E
    public final L u(long j8, Runnable runnable, E6.i iVar) {
        Executor executor = this.f7492s;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule(runnable, j8, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e8) {
                n0(iVar, e8);
            }
        }
        return scheduledFutureSchedule != null ? new K(scheduledFutureSchedule) : A.f7467z.u(j8, runnable, iVar);
    }
}