如何在同一线程上继续执行Firebase Task任务

嘿，刚好我在SyncAdapter里处理Firebase任务时踩过一模一样的坑，给你几个靠谱的解决方案：

核心问题原因 #

Firebase的addOnCompleteListener默认会把回调派发到UI主线程，而SyncAdapter的onPerformSync本身是在后台线程执行的，这就导致你后续的操作跑到主线程，调用Tasks.await时自然就触发了主线程的异常。解决的关键就是让Firebase任务的回调始终绑定在SyncAdapter的后台线程（或者你指定的后台线程池）上。

方案1：给addOnCompleteListener指定后台Executor #

直接在调用回调方法时传入一个后台线程的Executor，这样回调代码就会在后台线程执行：

// 可以用自定义的后台线程池，或者复用SyncAdapter所在的线程资源
Executor backgroundExecutor = Executors.newSingleThreadExecutor();

yourFirebaseTask.addOnCompleteListener(backgroundExecutor, new OnCompleteListener<YourResultType>() {
    @Override
    public void onComplete(@NonNull Task<YourResultType> task) {
        // 这里的代码100%在后台线程执行，放心操作
        if (task.isSuccessful()) {
            YourResultType result = task.getResult();
            // 继续你的后台逻辑，比如更新本地数据库、处理数据等
        } else {
            Exception error = task.getException();
            // 处理任务失败的情况
        }
    }
});

如果你的SyncAdapter是单线程执行的，也可以用当前线程的Handler来构建Executor，保证回调和SyncAdapter在同一个线程：

Handler backgroundHandler = new Handler(Looper.myLooper());
Executor backgroundExecutor = backgroundHandler::post;

方案2：用continueWith/continueWithTask链式处理（适合多任务串联） #

如果你需要在第一个Firebase任务完成后，继续执行另一个异步任务，用continueWith或continueWithTask并指定后台Executor是更优雅的方式：

Executor backgroundExecutor = Executors.newSingleThreadExecutor();

yourFirebaseTask.continueWith(backgroundExecutor, new Continuation<YourResultType, Void>() {
    @Override
    public Void then(@NonNull Task<YourResultType> task) throws Exception {
        // 这个回调同样在后台线程
        if (task.isSuccessful()) {
            // 处理第一个任务的结果
        } else {
            throw task.getException(); // 抛出异常会让后续任务进入失败状态
        }
        return null;
    }
});

如果后续还要执行另一个Firebase异步任务，用continueWithTask可以直接返回新的Task，实现链式调用：

yourFirebaseTask.continueWithTask(backgroundExecutor, new Continuation<YourResultType, Task<AnotherResultType>>() {
    @Override
    public Task<AnotherResultType> then(@NonNull Task<YourResultType> task) throws Exception {
        if (task.isSuccessful()) {
            // 基于第一个任务的结果，发起第二个Firebase任务
            return anotherFirebaseOperation(task.getResult());
        } else {
            throw task.getException();
        }
    }
}).addOnCompleteListener(backgroundExecutor, new OnCompleteListener<AnotherResultType>() {
    @Override
    public void onComplete(@NonNull Task<AnotherResultType> task) {
        // 最终的收尾操作，依然在后台线程
    }
});

避坑提醒 #

• 绝对不要在UI主线程调用Tasks.await，这是Firebase明确禁止的操作，会直接抛出你遇到的异常。
• 如果复用SyncAdapter的线程，注意不要阻塞线程太久，避免影响SyncAdapter的正常同步周期。

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