SPAIN TV+ v2.14.8版本的 MD5 值为:fb654ec376ec94e584d29f71bc1f6f4b

以下内容为反编译后的 c.java 源代码,内容仅作参考


package t5;

import java.lang.Thread;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import q5.p;
import q5.w;
public abstract class c implements p {
    private ScheduledThreadPoolExecutor f21165a;

    class a extends ScheduledThreadPoolExecutor {
        a(int i8, ThreadFactory threadFactory) {
            super(i8, threadFactory);
        }

        @Override
        protected void afterExecute(Runnable runnable, Throwable th) {
            super.afterExecute(runnable, th);
            if (th == null && (runnable instanceof Future)) {
                Future future = (Future) runnable;
                try {
                    if (future.isDone()) {
                        future.get();
                    }
                } catch (InterruptedException unused) {
                    Thread.currentThread().interrupt();
                } catch (CancellationException unused2) {
                } catch (ExecutionException e8) {
                    th = e8.getCause();
                }
            }
            if (th != null) {
                c.this.f(th);
            }
        }
    }

    private class b implements ThreadFactory {

        class a implements Thread.UncaughtExceptionHandler {
            a() {
            }

            @Override
            public void uncaughtException(Thread thread, Throwable th) {
                c.this.f(th);
            }
        }

        private b() {
        }

        b(c cVar, a aVar) {
            this();
        }

        @Override
        public Thread newThread(Runnable runnable) {
            Thread newThread = c.this.d().newThread(runnable);
            w e8 = c.this.e();
            e8.a(newThread, "FirebaseDatabaseWorker");
            e8.b(newThread, true);
            e8.c(newThread, new a());
            return newThread;
        }
    }

    public c() {
        a aVar = new a(1, new b(this, null));
        this.f21165a = aVar;
        aVar.setKeepAliveTime(3L, TimeUnit.SECONDS);
    }

    public static String g(Throwable th) {
        if (th instanceof OutOfMemoryError) {
            return "Firebase Database encountered an OutOfMemoryError. You may need to reduce the amount of data you are syncing to the client (e.g. by using queries or syncing a deeper path). See https://firebase.google.com/docs/database/ios/structure-data#best_practices_for_data_structure and https://firebase.google.com/docs/database/android/retrieve-data#filtering_data";
        }
        if (th instanceof NoClassDefFoundError) {
            return "A symbol that the Firebase Database SDK depends on failed to load. This usually indicates that your project includes an incompatible version of another Firebase dependency. If updating your dependencies to the latest version does not resolve this issue, please file a report at https://github.com/firebase/firebase-android-sdk";
        }
        if (th instanceof l5.b) {
            return "";
        }
        return "Uncaught exception in Firebase Database runloop (" + com.google.firebase.database.c.f() + "). If you are not already on the latest version of the Firebase SDKs, try updating your dependencies. Should this problem persist, please file a report at https://github.com/firebase/firebase-android-sdk";
    }

    @Override
    public void a() {
        this.f21165a.setCorePoolSize(1);
    }

    @Override
    public void b(Runnable runnable) {
        this.f21165a.execute(runnable);
    }

    public ScheduledExecutorService c() {
        return this.f21165a;
    }

    protected ThreadFactory d() {
        return Executors.defaultThreadFactory();
    }

    protected w e() {
        return w.f20055a;
    }

    public abstract void f(Throwable th);
}