[线程优化]代码提交

app/src/main/java/com/mogo/launcher/MogoApplication.java

@@ -1,9 +1,21 @@
 package com.mogo.launcher;
 
 import com.mogo.eagle.core.function.main.MainMoGoApplication;
+import android.content.Context;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
 import com.mogo.eagle.core.utilcode.mogo.logger.LogLevel;
 import com.mogo.eagle.core.utilcode.mogo.logger.Logger;
 import com.mogo.launcher.crash.CrashSystem;
+import com.mogo.thread.ext.core.ThreadManager;
+import com.mogo.thread.ext.core.config.ThreadConfig;
+
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.RejectedExecutionHandler;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @author congtaowang
@@ -13,6 +25,41 @@ import com.mogo.launcher.crash.CrashSystem;
  */
 public class MogoApplication extends MainMoGoApplication {
 
+    @Override
+    protected void attachBaseContext(Context base) {
+        super.attachBaseContext(base);
+        ThreadConfig.Builder builder = new ThreadConfig.Builder().listener(new ThreadConfig.TaskExecuteListener() {
+            @Override
+            public boolean isEnabled() {
+                return true; // 如果返回true，会有后续的回调；如果返回false, 不会有后续的回调
+            }
+
+            @Override
+            public void onExecutorBefore(@NonNull Runnable runnable) {
+                //每个任务执行前回调
+            }
+
+            @Override
+            public void onExecutorAfter(@NonNull Runnable runnable) {
+                //每个任务执行后回调
+            }
+
+            /**
+             * @param core 线程池的核心数
+             * @param max  线程池的最大线程数
+             * @param active 线程池正在活跃的任务数
+             * @param completed 线程池已完成的任务数
+             */
+            @Override
+            public void onExecutorStateChanged(@NonNull ThreadPoolExecutor pool, int core, int max, int active, long completed) {
+                //线程池在执行过程，状态变化回调
+                //Log.d("POOL", "core:" + core + ";max:" + max + ";active:" + active + ";completed:" + completed);
+            }
+        });
+        builder.loggable(false);
+        ThreadManager.INSTANCE.init(builder);
+    }
+
     @Override
     protected void initCrashConfig() {
         CrashSystem crashSystem = CrashSystem.getInstance(this);