package defpackage;

import java.lang.reflect.Method;
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: renamed from: ᵲᴵˁ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4513 extends AbstractC1307 implements InterfaceC4129 {

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final Executor f17167;

    public C4513(Executor executor) {
        Method method;
        this.f17167 = executor;
        Method method2 = AbstractC1000.f4371;
        try {
            ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = executor instanceof ScheduledThreadPoolExecutor ? (ScheduledThreadPoolExecutor) executor : null;
            if (scheduledThreadPoolExecutor != null && (method = AbstractC1000.f4371) != null) {
                method.invoke(scheduledThreadPoolExecutor, Boolean.TRUE);
            }
        } catch (Throwable unused) {
        }
    }

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

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

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

    @Override // defpackage.AbstractC2071
    public final String toString() {
        return this.f17167.toString();
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈᵲᵢ */
    public final InterfaceC0083 mo7668(long j, Runnable runnable, InterfaceC3822 interfaceC3822) {
        Executor executor = this.f17167;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule(runnable, j, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e) {
                CancellationException cancellationException = new CancellationException("The task was rejected");
                cancellationException.initCause(e);
                InterfaceC4645 interfaceC4645 = (InterfaceC4645) interfaceC3822.mo2664(C3664.f13909);
                if (interfaceC4645 != null) {
                    interfaceC4645.mo6096(cancellationException);
                }
            }
        }
        return scheduledFutureSchedule != null ? new C4957(scheduledFutureSchedule) : RunnableC4323.f16461.mo7668(j, runnable, interfaceC3822);
    }

    @Override // defpackage.InterfaceC4129
    /* JADX INFO: renamed from: ˈⁱᵡ */
    public final void mo7669(long j, C3453 c3453) {
        Executor executor = this.f17167;
        ScheduledFuture<?> scheduledFutureSchedule = null;
        ScheduledExecutorService scheduledExecutorService = executor instanceof ScheduledExecutorService ? (ScheduledExecutorService) executor : null;
        if (scheduledExecutorService != null) {
            ʾˀᵯˁ r1 = new ʾˀᵯˁ(this, 25, c3453);
            InterfaceC3822 interfaceC3822 = c3453.f13320;
            try {
                scheduledFutureSchedule = scheduledExecutorService.schedule((Runnable) r1, j, TimeUnit.MILLISECONDS);
            } catch (RejectedExecutionException e) {
                CancellationException cancellationException = new CancellationException("The task was rejected");
                cancellationException.initCause(e);
                InterfaceC4645 interfaceC4645 = (InterfaceC4645) interfaceC3822.mo2664(C3664.f13909);
                if (interfaceC4645 != null) {
                    interfaceC4645.mo6096(cancellationException);
                }
            }
        }
        if (scheduledFutureSchedule != null) {
            c3453.m7886(new C1780(0, scheduledFutureSchedule));
        } else {
            RunnableC4323.f16461.mo7669(j, c3453);
        }
    }

    @Override // defpackage.AbstractC2071
    /* JADX INFO: renamed from: ᵜᵤ */
    public final void mo2301(InterfaceC3822 interfaceC3822, Runnable runnable) {
        try {
            this.f17167.execute(runnable);
        } catch (RejectedExecutionException e) {
            CancellationException cancellationException = new CancellationException("The task was rejected");
            cancellationException.initCause(e);
            InterfaceC4645 interfaceC4645 = (InterfaceC4645) interfaceC3822.mo2664(C3664.f13909);
            if (interfaceC4645 != null) {
                interfaceC4645.mo6096(cancellationException);
            }
            C4681 c4681 = AbstractC0307.f1986;
            ExecutorC1834.f7291.mo2301(interfaceC3822, runnable);
        }
    }

    @Override // defpackage.AbstractC1307
    /* JADX INFO: renamed from: ᵵᵸᵕᵸ */
    public final Executor mo3833() {
        return this.f17167;
    }
}