Java/Android技术咨询：Worker Thread与HandlerThread间通信实现方案

我完全懂你的困扰——Android开发里的线程通信示例几乎全是围绕UI Thread转，跨工作线程的通信确实很少被详细讲解。不过你用HandlerThread做任务分发的思路本身就很合适，其实只需要利用HandlerThread自带的Looper和Handler，就能轻松实现Worker Thread向它回传信息，核心就是让每个Worker Thread持有HandlerThread的Handler引用。

核心思路 #

HandlerThread启动后会在自身线程中创建Looper，我们可以基于这个Looper创建一个专属Handler，这个Handler发送的所有消息都会被HandlerThread的线程处理，完全独立于UI Thread。Worker Thread只需要拿到这个Handler，就能通过它向HandlerThread发送消息或任务。

具体实现步骤 #

1. 初始化HandlerThread并创建它的专属Handler

首先启动HandlerThread，并在它的Looper环境下创建Handler，用来接收Worker Thread的回传信息：

// 定义消息常量，方便区分不同类型的回传
private static final int WORKER_TASK_FINISHED = 1;
private static final int WORKER_TASK_PROGRESS = 2;

// 初始化并启动HandlerThread
HandlerThread taskDispatcherThread = new HandlerThread("TaskDispatcher");
taskDispatcherThread.start();

// 创建绑定到HandlerThread Looper的Handler，用于处理回传消息
Handler dispatcherHandler = new Handler(taskDispatcherThread.getLooper()) {
    @Override
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        switch (msg.what) {
            case WORKER_TASK_FINISHED:
                // 处理Worker线程完成任务的回传
                String taskResult = (String) msg.obj;
                int taskId = msg.arg1;
                Log.d("Dispatcher", "任务" + taskId + "完成，结果：" + taskResult);
                // 这里可以继续分发新任务、更新任务队列等操作
                break;
            case WORKER_TASK_PROGRESS:
                // 处理Worker线程的进度回传
                int progress = msg.arg1;
                Log.d("Dispatcher", "任务进度：" + progress + "%");
                break;
        }
    }
};

2. 让Worker Thread持有dispatcherHandler并回传信息

每个Worker Thread在执行任务时，通过持有的dispatcherHandler向HandlerThread发送消息：

public class WorkerTask implements Runnable {
    private final Handler dispatcherHandler;
    private final int taskId;

    public WorkerTask(Handler dispatcherHandler, int taskId) {
        this.dispatcherHandler = dispatcherHandler;
        this.taskId = taskId;
    }

    @Override
    public void run() {
        // 模拟耗时任务执行
        for (int i = 0; i <= 100; i += 20) {
            // 回传任务进度
            Message progressMsg = Message.obtain();
            progressMsg.what = WORKER_TASK_PROGRESS;
            progressMsg.arg1 = i;
            dispatcherHandler.sendMessage(progressMsg);

            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        // 任务完成后回传结果
        Message finishMsg = Message.obtain();
        finishMsg.what = WORKER_TASK_FINISHED;
        finishMsg.arg1 = taskId;
        finishMsg.obj = "处理完成的结果数据";
        dispatcherHandler.sendMessage(finishMsg);
    }
}

3. 分发任务到Worker Thread

可以用线程池来管理多个Worker Thread，把任务分发出去：

// 创建固定大小的线程池，管理Worker线程
ExecutorService workerThreadPool = Executors.newFixedThreadPool(3);

// 分发5个任务
for (int i = 0; i < 5; i++) {
    workerThreadPool.execute(new WorkerTask(dispatcherHandler, i));
}

注意事项 #

• 内存泄漏与线程停止：在页面销毁或不再需要HandlerThread时，一定要调用taskDispatcherThread.quitSafely()来停止Looper，避免内存泄漏。
• 复杂数据传递：如果需要传递复杂对象，除了用msg.obj，还可以通过msg.setData(Bundle)来携带数据，Bundle支持序列化对象的传递。
• 替代方案：除了发送Message，也可以用dispatcherHandler.post(Runnable)的方式，直接让HandlerThread执行一段代码，这也是一种高效的通信方式：

  dispatcherHandler.post(() -> {
      // 这段代码会在HandlerThread的线程中执行
      updateTaskQueue(taskId);
  });
  

这样就能完美实现Worker Thread向HandlerThread的通信，完全不需要依赖UI Thread，符合你的业务场景需求。

内容的提问来源于stack exchange，提问作者user2383867