Android SQL数据库分页加载安全实践求助：解决重复加载问题

嘿，我明白你遇到的这个分页加载重复数据的头疼问题了——之前用同步锁、原子布尔值要么没彻底解决，要么体验不好。咱们从根源上梳理，给你一套可靠又优雅的方案，保证同一时间只有一个加载线程在跑，再也不会出现重复加载的情况。

问题根源复盘 #

你之前的问题核心在于：

• 依赖列表当前的item count作为分页起始位置，但UI线程更新列表和后台线程获取count的时机不同步，导致线程B拿到了线程A还没更新的旧count
• 虽然用了SingleThreadExecutor，但状态标记的时机不对，没在提交任务前就拦截重复请求

解决方案：状态锁+独立分页偏移量 #

咱们用三个关键点来解决问题：

1. 用**原子布尔值isLoading**在提交任务前拦截重复请求
2. 维护独立的分页偏移量currentOffset，代替从列表count获取起始位置，彻底避免UI更新延迟带来的错误
3. 利用SingleThreadExecutor的串行特性，确保后台任务按顺序执行

完整代码实现 #

1. 定义核心变量（在你的Fragment/Activity中）

// 单线程执行器，确保后台任务串行执行
private ExecutorService executorService = Executors.newSingleThreadExecutor();
// 原子布尔值，标记当前是否正在加载，线程安全
private AtomicBoolean isLoading = new AtomicBoolean(false);
// 独立维护分页起始偏移量，代替从列表count获取
private int currentOffset = 0;
// 每页加载的数据量，可根据需求调整
private static final int PAGE_SIZE = 20;

2. 优化loadMore方法

在提交任务前先检查加载状态，避免重复提交：

private void loadMore() {
    // 页面已销毁/正在加载中，直接返回
    if (!isAdded() || isLoading.get()) {
        return;
    }
    
    // 标记为正在加载
    isLoading.set(true);
    // 把当前偏移量传给后台任务，不用再从列表获取
    executorService.execute(new AsyncLoadMoreHashTags(getContext(), this, esaphTagAdapterVertical, currentOffset));
}

3. 重构后台加载任务

后台任务直接接收传入的偏移量，不用再依赖列表count，加载完成后回到主线程更新状态和偏移量：

public class AsyncLoadMoreHashTags extends MyDataLoaderClass {
    private final int loadOffset;
    private final SpecialRecylerView recyclerView;
    private final EsaphTagAdapterVertical adapter;
    private final Context context;

    public AsyncLoadMoreHashTags(Context context, DataBaseLoadWaiter loadWaiter, 
                                EsaphTagAdapterVertical adapter, SpecialRecylerView recyclerView, int offset) {
        super(context, loadWaiter, recyclerView);
        this.context = context;
        this.adapter = adapter;
        this.recyclerView = recyclerView;
        this.loadOffset = offset;
    }

    @Override
    public void run() {
        List<Object> objectList = null;
        SQLHashtags sqlHashtags = null;
        try {
            sqlHashtags = new SQLHashtags(context);
            if (loadOffset <= 0) {
                // 第一次加载，获取热门标签
                objectList = sqlHashtags.getMostUsedHashtags();
            } else {
                // 分页加载，用传入的偏移量和每页大小
                // 注意：这里需要调整你的SQL语句为LIMIT ?, ?，避免SQL注入
                objectList = sqlHashtags.getAllHashtagLimited(loadOffset, PAGE_SIZE);
            }
        } catch (Exception ec) {
            Log.i(getClass().getName(), "AsyncLoadMoreHashTags run() failed: " + ec);
        } finally {
            // 关闭数据库资源
            if (sqlHashtags != null) {
                sqlHashtags.close();
            }
            // 回到主线程更新UI和状态
            recyclerView.post(() -> {
                if (objectList != null && !objectList.isEmpty()) {
                    // 添加新数据到适配器
                    adapter.addAll(objectList);
                    // 更新偏移量，用实际加载的数量（避免最后一页数据不足时重复加载）
                    currentOffset += objectList.size();
                }
                
                // 重置加载状态，允许下一次加载
                isLoading.set(false);
                
                // 可选：如果加载的数据小于每页大小，说明没有更多数据了
                if (objectList == null || objectList.size() < PAGE_SIZE) {
                    // 这里可以标记没有更多数据，比如设置hasMore = false，不再触发loadMore
                }
            });
        }
    }
}

4. 优化滚动监听触发逻辑

确保只有在没有加载中、还有更多数据且滚动到接近底部时才触发加载：

recyclerView.addOnScrollListener(new RecyclerView.OnScrollListener() {
    @Override
    public void onScrolled(@NonNull RecyclerView recyclerView, int dx, int dy) {
        super.onScrolled(recyclerView, dx, dy);
        LinearLayoutManager layoutManager = (LinearLayoutManager) recyclerView.getLayoutManager();
        if (layoutManager == null) return;
        
        int visibleItemCount = layoutManager.getChildCount();
        int totalItemCount = layoutManager.getItemCount();
        int firstVisibleItemPosition = layoutManager.findFirstVisibleItemPosition();
        
        // 当滚动到距离底部5个item时触发加载（可调整阈值）
        boolean shouldLoad = (visibleItemCount + firstVisibleItemPosition) >= totalItemCount - 5;
        if (shouldLoad && !isLoading.get() && hasMoreData()) { // hasMoreData()是你判断是否还有数据的方法
            loadMore();
        }
    }
});

额外优化建议 #

• 如果你的项目允许，推荐使用Room Persistence Library配合Paging3库，这两个库原生支持分页加载、异步查询和状态管理，完全不用手动处理线程和重复加载问题，代码会更简洁
• 数据库操作一定要在后台线程执行，并且确保资源在finally块中关闭，避免内存泄漏
• 可以添加加载失败的重试逻辑，比如在catch块中记录错误，回到主线程提示用户重试

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