Android 与 ViewModel 和 CameraX 的线程间通信最佳实践？

问：

我有以下情况（查看下面的代码）：

1. 从 CameraX 用例的循环中获取ImageProxyImageAnalyzer
2. 分析图像（大约需要 20 毫秒）并返回一些信息，close()ImageProxy
3. 通过 AsyncTask 分析提取的信息（大约需要 500 到 3000 毫秒）
4. 如果成功，则显示结果

我有一些片段，这取决于任务 1 的成功程度。和 2.是（特别是 PreviewView 片段和一些结果页面）。目前，他们收到 .当图像被任一任务 1 分析时。或 2.我用 .这当然不理想，因为我还需要在我的任务中监听该状态，以防上一个图像产生了我可以显示给用户的结果。ViewModelviewModel.analyzerState.postValue(<newState>)

我现在的问题如下：
当结果准备就绪时，任务 1。或 2.可能仍在运行并产生另一个结果，然后触发 UI 更新两次。我不想这样，但我仍然希望任务并行运行，以防前一个任务失败（这种情况经常发生）。当我确定我有结果时，我希望取消任务（我已经调用了 AsyncTask，但这不起作用）。我认为我的问题是使用 作为线程间通信的消息传递工具，因为我在任务 1 中设置了状态。以及任务 2 中。并在循环中聆听它。cancel()ViewModel

我能找到的唯一信息是使用 Kotlin 协程，这显然是为使用 而制作的，但我使用的是 Java。ViewModel

解决此类问题的标准方法是什么？如何在各种线程和片段之间安全地进行通信？

法典：

void analyzeImage(ImageProxy imageProxy) {    // loop called by CameraX
    if (viewModel.analyzerState.getValue() == 'done') {
        imageProxy.close();
        return;
    }

    viewModel.analyzerState.postValue('extracting');

    Data data = extractData(imageProxy);

    imageProxy.close();

    if (data.isValid()) {
        viewModel.analyzerState.postValue('analyzing');
        new DataAnalyzeTask.execute(data);
    } else {
        viewModel.analyzerState.postValue('idle');
    }
}

// UI listens with
viewModel.analyzerState.observe(getViewLifecycleOwner(), state -> { /*...*/ } );