Android: как добавлять элементы и обновлять список при использовании PagedList?

Я использовал PagedList для загрузки страницы элементов и отображения их в RecyclerView, и он успешно отображает список чисел (0,1,2,3....,99), список всегда можно прокручивать вверх и вниз без любая проблема. Когда я попытался нажать кнопку, чтобы вызвать appendItems() для добавления новых данных, это все еще нормально. Однако приложение вылетало, когда я прокручивал список.

java.util.ConcurrentModificationException
    at java.util.AbstractList$SubAbstractList.size(AbstractList.java:360)
    at androidx.paging.PagedStorage.get(PagedStorage.java:153)
    at androidx.paging.PagedList.get(PagedList.java:384)
    at androidx.paging.AsyncPagedListDiffer.getItem(AsyncPagedListDiffer.java:206)
    at androidx.paging.PagedListAdapter.getItem(PagedListAdapter.java:156)
    at com.mysample.pagedlist.MyPagedListAdapter.onBindViewHolder(MyPagedListAdapter.java:38)
    at com.mysample.pagedlist.MyPagedListAdapter.onBindViewHolder(MyPagedListAdapter.java:19)

Кажется, я не знаю, как правильно добавить больше данных и обновить дисплей. Может ли кто-нибудь сказать мне, как это решить?

API служит базой данных и дао

public class Api {
    private static List<String> list = null;

    private static void initListIfNeeded() {
        if (list == null) {
            list = new ArrayList<>();
            for (int i = 0; i < 100; i++) {
                list.add("" + i);
            }
        }
    }

    public static List<String> pageItems(int page, int pageSize) {
        initListIfNeeded();
        int start = page * pageSize;
        int end = (page + 1) * pageSize;
        if (end > list.size()) {
            end = list.size();
        }
        if (page < 0 || start >= list.size()) {
            return new ArrayList<>();
        } else {
            return list.subList(start, end);
        }
    }

    public static void appendItems() {
        initListIfNeeded();
        int size = list.size();
        for (int i = 0; i < 10; i++) {
            list.add("" + (size + i));
        }
    }
}

DataSource используется для обработки разбиения на страницы данных

public class MyDataSource extends PageKeyedDataSource<Integer, String> {

    public MyDataSource() {
    }

    @Override
    public void loadInitial(@NonNull LoadInitialParams<Integer> params, @NonNull LoadInitialCallback<Integer, String> callback) {
        callback.onResult(Api.pageItems(0, params.requestedLoadSize), -1, 1);
    }

    @Override
    public void loadBefore(@NonNull LoadParams<Integer> params, @NonNull LoadCallback<Integer, String> callback) {
        callback.onResult(Api.pageItems(params.key, params.requestedLoadSize), params.key - 1);
    }

    @Override
    public void loadAfter(@NonNull LoadParams<Integer> params, @NonNull LoadCallback<Integer, String> callback) {
        callback.onResult(Api.pageItems(params.key, params.requestedLoadSize), params.key + 1);
    }

}

Соответствующий класс ViewModel

public class MyViewModel extends ViewModel {

    public LiveData<PagedList<String>> list;

    public MyViewModel() {
        list = new LivePagedListBuilder<>(new DataSource.Factory<Integer, String>() {
            @Override
            public DataSource<Integer, String> create() {
                return new MyDataSource();
            }
        },  new PagedList.Config.Builder().setPageSize(20).setInitialLoadSizeHint(20).build()).build();
    }

    public void appendItems() {
        Api.appendItems();
    }
}

Активность

public class PagedListActivity extends AppCompatActivity {

    private MyPagedListAdapter adapter;
    private MyViewModel viewModel;
    private RecyclerView recyclerView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_paged_list);
        adapter = new MyPagedListAdapter(LayoutInflater.from(this));

        recyclerView = findViewById(R.id.recyclerView);
        recyclerView.setLayoutManager(new LinearLayoutManager(this));
        recyclerView.setAdapter(adapter);
        viewModel = ViewModelProviders.of(this).get(MyViewModel.class);
        viewModel.list.observe(this, new Observer<PagedList<String>>() {
            @DebugLog
            @Override
            public void onChanged(PagedList<String> strings) {
                adapter.submitList(strings);
            }
        });
    }

    @DebugLog
    public void onClick(View view) {
        viewModel.appendItems();
    }
}

Адаптер

public class MyPagedListAdapter extends PagedListAdapter<String, MyPagedListAdapter.VH> {

    private LayoutInflater inflater;

    protected MyPagedListAdapter(LayoutInflater inflater) {
        super(DIFF_CALLBACK);
        this.inflater = inflater;
    }

    @NonNull
    @Override
    public VH onCreateViewHolder(@NonNull ViewGroup parent, int viewType) {
        View view = inflater.inflate(R.layout.item_text, parent, false);
        return new VH(view);
    }

    @Override
    public void onBindViewHolder(@NonNull VH holder, int position) {
        holder.setData(getItem(position));
    }

    public class VH extends RecyclerView.ViewHolder {

        private final TextView txt;

        public VH(@NonNull View itemView) {
            super(itemView);
            txt = itemView.findViewById(R.id.txt);
        }

        public void setData(String text) {
            txt.setText(text);
        }
    }

    private static DiffUtil.ItemCallback<String> DIFF_CALLBACK = new DiffUtil.ItemCallback<String>() {
        @Override
        public boolean areItemsTheSame(@NonNull String oldItem, @NonNull String newItem) {
            return oldItem.equalsIgnoreCase(newItem);
        }

        @Override
        public boolean areContentsTheSame(@NonNull String oldItem, @NonNull String newItem) {
            return oldItem.equalsIgnoreCase(newItem);
        }
    };

}

person Season    schedule 19.10.2018    source источник


Ответы (1)


Из этой трассировки стека:

java.util.ConcurrentModificationException
    at java.util.AbstractList$SubAbstractList.size(AbstractList.java:360)

мы можем сказать, что

а) приложение аварийно завершает работу, когда кто-то пытается изменить список во время итерации по списку
б) это происходит в экземпляре SubAbstractList (который создается при вызове list.subList(start, end);

Приложение аварийно завершает работу, поскольку подсписок, созданный до изменения исходного списка, больше недействителен после изменения (добавления элементов) исходного списка

Вместо возврата list.subList(start, end); из Api#pageItems попробуйте
вернуть new ArrayList<>(list.subList(start, end));

Чтобы RecyclerView отображал ваши изменения, вы должны вызвать Adapter#notifyItemRangeInserted или адаптер RW

person TarasAntoshchuk    schedule 19.10.2018
comment
спасибо, модификация устранила ошибку, однако добавленные элементы не отображаются в списке, что мне сделать, чтобы обновить список? - person Season; 19.10.2018
comment
добавляя adapter.notifyItemRangeInserted(some_start_pos, some_count) после viewModel.appendItems() в Activity , он позволяет отображать в списке больше элементов, когда список не прокручивается до конца. Если список прокручивается до конца и я нажимаю кнопку для добавления элементов, ничего не происходит; больше не отображаются элементы - person Season; 19.10.2018
comment
очень поздно к этому от @Season, вы когда-нибудь находили решение этой проблемы? - person davy307; 08.11.2020