41 lines
1.2 KiB
Java
41 lines
1.2 KiB
Java
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;
|
|
}
|
|
}
|