package p037.p123.p124.p134;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import p037.p123.AbstractC2562;
import p138.p139.p143.p144.C2803;

/* JADX INFO: renamed from: މ.ޗ.ޘ.ސ.ލ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C2713 {

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public static final String f8402 = AbstractC2562.m4622("WorkTimer");

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final ThreadFactory f8403 = new ThreadFactoryC2714(this);

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public final Map<String, RunnableC2716> f8405 = new HashMap();

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public final Map<String, InterfaceC2715> f8406 = new HashMap();

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public final Object f8407 = new Object();

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final ScheduledExecutorService f8404 = Executors.newSingleThreadScheduledExecutor(this.f8403);

    /* JADX INFO: renamed from: މ.ޗ.ޘ.ސ.ލ$֏, reason: contains not printable characters */
    public class ThreadFactoryC2714 implements ThreadFactory {

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public int f8408 = 0;

        public ThreadFactoryC2714(C2713 c2713) {
        }

        @Override // java.util.concurrent.ThreadFactory
        public Thread newThread(Runnable runnable) {
            Thread threadNewThread = Executors.defaultThreadFactory().newThread(runnable);
            StringBuilder sbM4889 = C2803.m4889("WorkManager-WorkTimer-thread-");
            sbM4889.append(this.f8408);
            threadNewThread.setName(sbM4889.toString());
            this.f8408++;
            return threadNewThread;
        }
    }

    /* JADX INFO: renamed from: މ.ޗ.ޘ.ސ.ލ$ؠ, reason: contains not printable characters */
    public interface InterfaceC2715 {
        /* JADX INFO: renamed from: ֏ */
        void mo4694(String str);
    }

    /* JADX INFO: renamed from: މ.ޗ.ޘ.ސ.ލ$ހ, reason: contains not printable characters */
    public static class RunnableC2716 implements Runnable {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final C2713 f8409;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public final String f8410;

        public RunnableC2716(C2713 c2713, String str) {
            this.f8409 = c2713;
            this.f8410 = str;
        }

        @Override // java.lang.Runnable
        public void run() {
            synchronized (this.f8409.f8407) {
                if (this.f8409.f8405.remove(this.f8410) != null) {
                    InterfaceC2715 interfaceC2715Remove = this.f8409.f8406.remove(this.f8410);
                    if (interfaceC2715Remove != null) {
                        interfaceC2715Remove.mo4694(this.f8410);
                    }
                } else {
                    AbstractC2562.m4623().mo4625("WrkTimerRunnable", String.format("Timer with %s is already marked as complete.", this.f8410), new Throwable[0]);
                }
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m4779(String str) {
        synchronized (this.f8407) {
            if (this.f8405.remove(str) != null) {
                AbstractC2562.m4623().mo4625(f8402, String.format("Stopping timer for %s", str), new Throwable[0]);
                this.f8406.remove(str);
            }
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m4780(String str, long j, InterfaceC2715 interfaceC2715) {
        synchronized (this.f8407) {
            AbstractC2562.m4623().mo4625(f8402, String.format("Starting timer for %s", str), new Throwable[0]);
            m4779(str);
            RunnableC2716 runnableC2716 = new RunnableC2716(this, str);
            this.f8405.put(str, runnableC2716);
            this.f8406.put(str, interfaceC2715);
            this.f8404.schedule(runnableC2716, j, TimeUnit.MILLISECONDS);
        }
    }
}