Android Studio中Java代码循环中断与静态变量问题求助

原因 #

break interloop/break outerloop写在Firebase异步回调的匿名内部类中，标签循环的作用域仅限于当前代码块，匿名内部类属于独立作用域，无法直接访问外层循环的标签；同时Firebase的get().addOnCompleteListener是异步执行的，外层for循环会在回调执行前完成迭代，就算break能访问标签也无法中断已执行的循环。

解决方案 #

方案1：布尔标志位+异步任务合并控制 #

用原子布尔变量标记是否中断循环，同时合并price和title的异步请求，确保逻辑同步：

private void initData() {
    adList = new ArrayList<>();
    AtomicBoolean stopOuterLoop = new AtomicBoolean(false);
    int i = 0;

    for (int k = 0; k < 3 && !stopOuterLoop.get(); k++) {
        UserRef.child(String.valueOf(i)).get().addOnCompleteListener(userTask -> {
            if (userTask.isSuccessful()) {
                DataSnapshot userSnapshot = userTask.getResult();
                if (userSnapshot.exists()) {
                    String userid = userSnapshot.getValue().toString();
                    AtomicBoolean stopInnerLoop = new AtomicBoolean(false);

                    for (int j = 0; j < 3 && !stopInnerLoop.get(); j++) {
                        // 合并两个异步请求
                        Task<DataSnapshot> priceTask = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("advertisement_price").get();
                        Task<DataSnapshot> titleTask = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("title").get();

                        Tasks.whenAll(priceTask, titleTask).addOnCompleteListener(allTask -> {
                            if (allTask.isSuccessful()) {
                                DataSnapshot priceSnapshot = priceTask.getResult();
                                if (!priceSnapshot.exists()) {
                                    stopInnerLoop.set(true); // 触发内层循环中断
                                    return;
                                }
                                String price = priceSnapshot.getValue().toString();
                                String title = titleTask.getResult().getValue().toString();
                                adList.add(new MainModel(price, title, R.drawable.google));
                            }
                        });
                    }
                } else {
                    stopOuterLoop.set(true); // 触发外层循环中断
                }
            }
        });
        i++;
    }
}

方案2：同步调用Firebase接口（子线程执行） #

将异步请求改为同步调用（必须在子线程执行，避免阻塞主线程），此时可直接使用标签break：

private void initData() {
    new Thread(() -> {
        adList = new ArrayList<>();
        int i = 0;
        outerloop:
        for (int k = 0; k < 3; k++) {
            try {
                DataSnapshot userSnapshot = UserRef.child(String.valueOf(i)).get().await();
                if (userSnapshot.exists()) {
                    String userid = userSnapshot.getValue().toString();
                    interloop:
                    for (int j = 0; j < 3; j++) {
                        try {
                            DataSnapshot priceSnapshot = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("advertisement_price").get().await();
                            if (!priceSnapshot.exists()) {
                                break interloop; // 直接中断内层循环
                            }
                            String price = priceSnapshot.getValue().toString();
                            DataSnapshot titleSnapshot = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("title").get().await();
                            String title = titleSnapshot.getValue().toString();
                            // 回到主线程更新列表（UI操作必须在主线程）
                            runOnUiThread(() -> adList.add(new MainModel(price, title, R.drawable.google)));
                        } catch (ExecutionException | InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                } else {
                    break outerloop; // 直接中断外层循环
                }
            } catch (ExecutionException | InterruptedException e) {
                e.printStackTrace();
            }
            i++;
        }
    }).start();
}

原因 #

Firebase的get().addOnCompleteListener是异步执行的，外层for循环会先执行adList.add(...)，此时回调里的price和title还未赋值；同时静态变量会被后续异步回调覆盖，无法保留对应迭代的正确值。

解决方案 #

移除静态变量，在异步回调内部处理数据，合并两个异步请求确保数据全部获取后再更新列表：

// 移除静态变量，改用局部变量
private void initData() {
    adList = new ArrayList<>();
    int i = 0;

    for (int k = 0; k < 3; k++) {
        UserRef.child(String.valueOf(i)).get().addOnCompleteListener(userTask -> {
            if (userTask.isSuccessful() && userTask.getResult().exists()) {
                String userid = userTask.getResult().getValue().toString();

                for (int j = 0; j < 3; j++) {
                    // 同时发起price和title的请求
                    Task<DataSnapshot> priceTask = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("advertisement_price").get();
                    Task<DataSnapshot> titleTask = AdvertisementsRef.child(userid).child(String.valueOf(j)).child("title").get();

                    // 等待两个请求完成后再处理数据
                    Tasks.whenAll(priceTask, titleTask).addOnCompleteListener(allTask -> {
                        if (allTask.isSuccessful()) {
                            DataSnapshot priceSnapshot = priceTask.getResult();
                            if (priceSnapshot.exists()) {
                                String price = priceSnapshot.getValue().toString();
                                String title = titleTask.getResult().getValue().toString();
                                // 确保数据赋值完成后再添加到列表
                                adList.add(new MainModel(price, title, R.drawable.google));
                                // 若需更新UI，切换到主线程
                                // runOnUiThread(() -> adapter.notifyDataSetChanged());
                            }
                        }
                    });
                }
            }
        });
        i++;
    }
}

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