Java方法异步代码执行顺序异常：如何让日志验证代码最后执行？

这问题我太熟了——Firebase Realtime Database的查询都是异步非阻塞的，onDataChange回调会在后台线程完成数据获取后才触发，而你的日志代码是同步执行的，自然会跑在回调前面。要让验证代码等两个查询都完成再执行，有几种靠谱的方案，我给你一一拆解：

方案一：手动计数法（简单易上手，适合新手） #

核心思路是设置一个计数器，每次查询完成（不管成功还是失败）就把计数器加1，当计数器达到2时，就执行你的验证逻辑。代码示例：

// 定义计数器，初始为0
private int completedQueries = 0;
// 假设postList和followingList是你已经声明好的全局/成员变量

// 第一个查询：获取帖子列表
DatabaseReference postsRef = FirebaseDatabase.getInstance().getReference("posts");
postsRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        postList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            Post post = snapshot.getValue(Post.class);
            postList.add(post);
        }
        // 查询完成，调用检查方法
        checkIfAllQueriesDone();
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        // 千万别忘了处理错误！不然查询失败的话计数器永远到不了2
        Log.e("Firebase", "帖子查询失败", databaseError.toException());
        checkIfAllQueriesDone();
    }
});

// 第二个查询：获取关注列表
DatabaseReference followingRef = FirebaseDatabase.getInstance().getReference("users/" + currentUserId + "/following");
followingRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        followingList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            String userId = snapshot.getKey();
            followingList.add(userId);
        }
        checkIfAllQueriesDone();
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        Log.e("Firebase", "关注列表查询失败", databaseError.toException());
        checkIfAllQueriesDone();
    }
});

// 验证触发方法
private void checkIfAllQueriesDone() {
    completedQueries++;
    if (completedQueries == 2) {
        // 两个查询都完成了！现在执行你的调试逻辑
        Log.d("Debug", "帖子列表大小：" + postList.size());
        Log.d("Debug", "关注列表大小：" + followingList.size());
        
        // 注意：如果用的是addValueEventListener（实时监听），记得重置计数器
        // 不然每次数据变化都会触发验证，可能不是你想要的
        completedQueries = 0;
    }
}

注意事项 #

• 如果只是一次性查询（不需要实时监听），推荐用addListenerForSingleValueEvent，避免不必要的回调触发。
• 必须在onCancelled里也调用检查方法，否则查询失败时计数器永远不会达标，验证代码永远不会执行。

方案二：CountDownLatch（并发工具类，优雅可控） #

如果你懂一点Java并发编程，CountDownLatch是更优雅的选择。它就像一个倒计时器，初始化时设置计数为2，每个查询完成就调用countDown()减1，当计数到0时，等待的线程就会被唤醒，执行后续逻辑。

// 初始化倒计时器，计数为2
CountDownLatch queryLatch = new CountDownLatch(2);

// 第一个查询
DatabaseReference postsRef = FirebaseDatabase.getInstance().getReference("posts");
postsRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        postList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            Post post = snapshot.getValue(Post.class);
            postList.add(post);
        }
        queryLatch.countDown(); // 计数减1
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        Log.e("Firebase", "帖子查询失败", databaseError.toException());
        queryLatch.countDown(); // 失败也要减计数，避免阻塞
    }
});

// 第二个查询
DatabaseReference followingRef = FirebaseDatabase.getInstance().getReference("users/" + currentUserId + "/following");
followingRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        followingList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            String userId = snapshot.getKey();
            followingList.add(userId);
        }
        queryLatch.countDown();
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        Log.e("Firebase", "关注列表查询失败", databaseError.toException());
        queryLatch.countDown();
    }
});

// 开启新线程等待查询完成（不能在主线程调用await，会导致ANR）
new Thread(() -> {
    try {
        queryLatch.await(); // 阻塞直到计数为0
        // 切换回主线程执行调试/UI操作（Firebase回调在主线程，但这里是新线程）
        runOnUiThread(() -> {
            Log.d("Debug", "帖子列表大小：" + postList.size());
            Log.d("Debug", "关注列表大小：" + followingList.size());
        });
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

方案三：CompletableFuture（Java 8+，现代异步编程） #

如果你的项目用的是Java 8及以上，CompletableFuture是最现代的解决方案，它支持链式调用，代码更简洁，扩展性也更好，适合复杂的异步流程。

// 把第一个查询包装成CompletableFuture
CompletableFuture<Void> postsFuture = new CompletableFuture<>();
DatabaseReference postsRef = FirebaseDatabase.getInstance().getReference("posts");
postsRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        postList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            Post post = snapshot.getValue(Post.class);
            postList.add(post);
        }
        postsFuture.complete(null); // 标记任务完成
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        Log.e("Firebase", "帖子查询失败", databaseError.toException());
        postsFuture.completeExceptionally(databaseError.toException()); // 标记任务失败
    }
});

// 包装第二个查询
CompletableFuture<Void> followingFuture = new CompletableFuture<>();
DatabaseReference followingRef = FirebaseDatabase.getInstance().getReference("users/" + currentUserId + "/following");
followingRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        followingList.clear();
        for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
            String userId = snapshot.getKey();
            followingList.add(userId);
        }
        followingFuture.complete(null);
    }

    @Override
    public void onCancelled(DatabaseError databaseError) {
        Log.e("Firebase", "关注列表查询失败", databaseError.toException());
        followingFuture.completeExceptionally(databaseError.toException());
    }
});

// 等待两个任务都完成，然后执行后续逻辑
CompletableFuture.allOf(postsFuture, followingFuture)
    .thenRun(() -> {
        // 切换回主线程操作
        runOnUiThread(() -> {
            Log.d("Debug", "帖子列表大小：" + postList.size());
            Log.d("Debug", "关注列表大小：" + followingList.size());
        });
    })
    .exceptionally(throwable -> {
        // 处理任何一个查询失败的情况
        Log.e("Firebase", "至少一个查询失败", throwable);
        return null;
    });

总结 #

• 新手优先选手动计数法，逻辑简单，容易理解和调试。
• 如果你熟悉并发编程，CountDownLatch是更优雅的选择，代码更清晰。
• 现代项目推荐用CompletableFuture，它支持更复杂的异步组合，比如多个任务依赖、异常处理等。

不管用哪种方案，一定要记得处理onCancelled回调，避免出现查询失败后验证代码永远不执行的情况！

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