Android 进程与线程：主线程阻塞问题、Handler、WorkThread、线程池工控实践

Android 进程与线程主线程阻塞问题、Handler、WorkThread、线程池工控实践工控设备卡成PPT大概率是你在主线程干了重活这篇把线程那点事儿掰碎了讲清楚。一、Android 进程与线程模型Android 应用启动时系统会为其创建一个进程并在该进程中启动一个主线程Main Thread。主线程也叫UI 线程负责处理界面绘制、用户事件分发、组件生命周期回调等。为什么不能在主线程做耗时操作核心原因一句话主线程承担着每 16ms 左右刷新一次屏幕60fps的重任。如果某个操作阻塞了主线程超过阈值系统就会弹出一个让所有开发者闻风丧胆的东西——ANRApplication Not Responding。常见的耗时操作包括网络请求HTTP / Socket 通信文件 I/O读写本地大文件数据库操作批量增删改查串口数据读取工控场景最常见的坑大量 CPU 计算图像处理、数据解析在工控板子上串口读取如果放在主线程数据量大的时候画面直接冻住按钮点不动这就是典型的主线程阻塞。二、ANR 机制详解ANR 不是随机触发的它有明确的超时阈值ANR 类型触发场景超时阈值Service TimeoutService 的 onCreate / onStartCommand 执行超时前台 20s / 后台 200sBroadcast TimeoutBroadcastReceiver.onReceive 执行超时前台 10s / 后台 60sInput Dispatch Timeout输入事件触摸/按键无响应5sContentProvider Timeout内容提供者发布超时10s注意一个常见误区很多人以为主线程耗时 5 秒就 ANR其实5 秒是输入事件派发超时。如果没有触摸事件进来主线程就算卡 10 秒也不一定弹 ANR——但界面肯定已经卡死了。真正让用户感知到的是输入无响应那条。工控设备往往是长时间无人触屏的所以 ANR 不一定弹出来但界面卡住一样致命——操作员按了停止按钮没反应设备还在跑。三、Handler 消息机制原理Handler 是 Android 线程间通信的核心机制涉及四个关键角色Message消息载体携带what标识、obj数据、arg1/arg2整型参数MessageQueue消息队列按时间排序的单链表结构Looper循环器不断从 MessageQueue 中取出 Message 分发给 HandlerHandler发送和处理消息的入口整个流程可以用一句话概括Handler 发送 Message → MessageQueue 入队 → Looper 循环取出 → Handler.handleMessage() 处理[子线程] Handler.sendMessage(msg) ↓ [MessageQueue] 按 when 排序入队 ↓ [Looper.loop()] 死循环轮询取出 ↓ [Handler.handleMessage()] 在 Handler 创建所在线程执行关键点Handler 的 handleMessage 在哪个线程执行取决于 Handler 在哪个线程创建。在主线程创建的 HandlerhandleMessage 就跑在主线程天然可以更新 UI。四、工作线程创建方式4.1 普通 Thread最原始的方式直接 new 一个线程newThread(()-{// 子线程执行耗时操作StringdatareadSerialPort();// 不能直接更新UI需要Handler切换}).start();缺点每次 new Thread 开销大无法管理线程数量容易造成 OOM。4.2 HandlerThread自带 Looper 的线程适合需要在该线程上创建 Handler 的场景HandlerThreadhandlerThreadnewHandlerThread(serial-worker);handlerThread.start();HandlerserialHandlernewHandler(handlerThread.getLooper()){OverridepublicvoidhandleMessage(NonNullMessagemsg){// 在HandlerThread线程中执行}};4.3 IntentService已废弃了解即可Android 8.0 后官方推荐用JobIntentService / WorkManager替代但在老项目里还能见到。它的特点是串行执行任务执行完自动停止。五、线程池使用线程池是工控开发中管理线程的最佳实践。核心类是ThreadPoolExecutor。5.1 参数详解ThreadPoolExecutorexecutornewThreadPoolExecutor(intcorePoolSize,// 核心线程数即使空闲也保留的线程数intmaximumPoolSize,// 最大线程数队列满后能扩展的最大线程数longkeepAliveTime,// 非核心线程空闲存活时间TimeUnitunit,// 时间单位BlockingQueueRunnableworkQueue,// 任务队列ThreadFactorythreadFactory,// 线程工厂可自定义线程名RejectedExecutionHandlerhandler// 拒绝策略);四种拒绝策略策略行为AbortPolicy默认抛出 RejectedExecutionExceptionCallerRunsPolicy由调用线程执行该任务DiscardPolicy直接丢弃DiscardOldestPolicy丢弃队列最老的任务再尝试提交5.2 工控场景线程池配置工控设备通常资源有限ARM Cortex-A 系列可能只有 1~4 核线程池不能无脑开大。推荐配置// 工控场景线程池核心2线程最大4线程队列128privatestaticfinalintCPU_COUNTRuntime.getRuntime().availableProcessors();privatestaticfinalintCORE_POOL_SIZEMath.max(2,Math.min(CPU_COUNT-1,4));privatestaticfinalintMAX_POOL_SIZECORE_POOL_SIZE*2;privatestaticfinalintQUEUE_CAPACITY128;publicstaticfinalThreadPoolExecutorWORK_EXECUTORnewThreadPoolExecutor(CORE_POOL_SIZE,MAX_POOL_SIZE,30L,TimeUnit.SECONDS,newLinkedBlockingQueue(QUEUE_CAPACITY),newThreadFactory(){privatefinalAtomicIntegermCountnewAtomicInteger(1);OverridepublicThreadnewThread(Runnabler){returnnewThread(r,control-worker-mCount.getAndIncrement());}},newThreadPoolExecutor.CallerRunsPolicy()// 队列满了让调用线程自己跑不丢任务);工控场景拒绝策略推荐CallerRunsPolicy——宁可让提交任务的线程自己执行也不能丢任务。丢一个继电器控制指令可能就是事故。六、工控实践串口数据读取用子线程 Handler 更新 UI下面是一个完整的串口通信线程 Handler 更新 UI 的实现publicclassSerialPortManager{privatestaticfinalintMSG_DATA_RECEIVED0x01;privatestaticfinalintMSG_ERROR0x02;// 主线程Handler用于更新UIprivatefinalHandlermUiHandler;// 串口工作线程privateHandlerThreadmSerialThread;privateHandlermSerialHandler;// 串口运行标志privatevolatilebooleanmRunningfalse;publicSerialPortManager(HandleruiHandler){this.mUiHandleruiHandler;}/** * 初始化串口读取线程 */publicvoidstart(){mSerialThreadnewHandlerThread(serial-read-thread);mSerialThread.start();mSerialHandlernewHandler(mSerialThread.getLooper()){OverridepublicvoidhandleMessage(NonNullMessagemsg){if(msg.whatMSG_DATA_RECEIVED){byte[]data(byte[])msg.obj;parseAndNotify(data);}}};mRunningtrue;// 启动读取循环mSerialHandler.post(this::readLoop);}/** * 串口读取循环在子线程执行 */privatevoidreadLoop(){while(mRunning){try{byte[]buffernewbyte[1024];intsizemInputStream.read(buffer);// 阻塞读取if(size0){byte[]datanewbyte[size];System.arraycopy(buffer,0,data,0,size);// 通过Handler切到主线程MessagemsgmUiHandler.obtainMessage(MSG_DATA_RECEIVED,data);mUiHandler.sendMessage(msg);}}catch(IOExceptione){mUiHandler.obtainMessage(MSG_ERROR,e.getMessage()).sendToTarget();break;}}}/** * 解析数据并通知UI */privatevoidparseAndNotify(byte[]data){// 协议帧解析帧头0xAA 长度 数据 校验if(data.length4)return;if(data[0]!(byte)0xAA)return;intlendata[1]0xFF;// ...解析逻辑}publicvoidstop(){mRunningfalse;if(mSerialThread!null){mSerialThread.quitSafely();}}}在 Activity 中使用publicclassMainActivityextendsAppCompatActivity{privateTextViewtvTempData;privateSerialPortManagermSerialManager;// UI Handler处理子线程发来的消息privatefinalHandlermUiHandlernewHandler(Looper.getMainLooper()){OverridepublicvoidhandleMessage(NonNullMessagemsg){switch(msg.what){caseSerialPortManager.MSG_DATA_RECEIVED:byte[]data(byte[])msg.obj;StringhexStrbytesToHex(data);tvTempData.setText(收到数据: hexStr);break;caseSerialPortManager.MSG_ERROR:Toast.makeText(MainActivity.this,串口错误: msg.obj,Toast.LENGTH_SHORT).show();break;}}};OverrideprotectedvoidonCreate(BundlesavedInstanceState){super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);tvTempDatafindViewById(R.id.tv_temp_data);mSerialManagernewSerialPortManager(mUiHandler);mSerialManager.start();}OverrideprotectedvoidonDestroy(){super.onDestroy();mSerialManager.stop();}}6.1 核心要点总结要点说明串口读取必须在子线程InputStream.read()是阻塞调用放主线程必卡UI 更新必须切回主线程子线程直接操作 View 会抛异常Handler 是线程切换的标准方式轻量、可控、生命周期清晰HandlerThread 适合持续轮询场景自带 Looper省去手动 prepare/loopvolatile 控制线程退出保证可见性避免死循环工控开发中线程管理是基本功。串口、网络、定时采集每一路数据流都应该有独立的工作线程通过 Handler 或回调将结果送到主线程刷新界面。把线程用好设备才能跑得稳。