package o;

import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;

/* loaded from: classes.dex */
public final class fYB {
    private static boolean b = c("rx3.purge-enabled", new RVV());

    private static boolean c(String str, fSS<String, String> fss) {
        try {
            String a = fss.a(str);
            if (a == null) {
                return true;
            }
            return "true".equals(a);
        } catch (Throwable th) {
            C13147fSI.c(th);
            return true;
        }
    }

    /* loaded from: classes.dex */
    static final class RVV implements fSS<String, String> {
        RVV() {
        }

        @Override // o.fSS
        public final /* synthetic */ String a(String str) throws Throwable {
            return System.getProperty(str);
        }
    }

    public static ScheduledExecutorService c(ThreadFactory threadFactory) {
        ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1, threadFactory);
        scheduledThreadPoolExecutor.setRemoveOnCancelPolicy(b);
        return scheduledThreadPoolExecutor;
    }
}