Как предотвратить ConcurrentModificationException при изменении ArrayAdapter из нескольких потоков? - PullRequest
1 голос
/ 06 июня 2019

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

Однако я получаю сообщение об ошибке:

java.util.ConcurrentModificationException
    at java.util.ArrayList$Itr.next(ArrayList.java:860)
    at UploadActivity$11$1.onFinish(UploadActivity.java:471)
    at FileUploader.upload(FileUploader.java:115)
    at UploadActivity$11.run(UploadActivity.java:458)

Я понимаю, что у меня есть несколько потоков, которые одновременно обращаются к моему адаптеру RecyclerView и изменяют его, но я не уверен, как решить проблему (мой код и попытка опубликованы ниже).


Сначала я перебираю выбранные элементы RecyclerView, получаю каждый выбранный файл и вызываю upload ()

// Loop through all selected RecyclerView items 
for (int i = 0; i < selectedIndicies.size(); i++) {

    // Get the i-th selected item
    Upload_Item_Model selectedItem = adapter.getFilteredData().get(selectedIndicies.get(i));

    // Get the file associated with the i-th selected item
    SaveFile file = getFileWithFilename(token, selectedItem.getTitle(), UploadActivity.this);

    // Upload the file
    uploadFile(file);
}

Затем я запускаю новый поток, начинаю загрузку и определяю обратный вызов onFinish ()

public void uploadFile(SaveFile saveFile) {

    ...

    new Thread() {

        @Override
        public void run() {

            // 
            // Uploads the given file, when the upload is complete
            // the onFinish() method is called and the file is passed
            // back so I can update the RecyclerView
            //

            FileUploader.upload(saveFile, new FileUploader.FileUploadListener() {

                @Override
                public void onFinish(SaveFile file) {

                    // Loop through all items in RecyclerView
                    for (Upload_Item_Model item : adapter.getFilteredData()) { // this is line 471 where the crash happens

                        //
                        // If the RecyclerView item has the same name
                        // as the returned file, then it is 
                        // the file I just uploaded
                        //

                        if (item.getTitle().equals(file.getFilename())) {
                            runOnUiThread(() -> {

                                // Removes the item from the adapter
                                adapter.removeItem(item);
                                adapter.notifyDataSetChanged();
                            });

                        }
                    }
                }
            });
        }
    }.start();
}

В адаптере у меня есть следующие функции, которые получают доступ и изменяют адаптеры ArrayList. Я попытался сделать эти темы безопасными без удачи.

public ArrayList<Upload_Item_Model> getFilteredData() {
    synchronized (this.filteredData) {
        return this.filteredData;
    }
}

public void removeItem(Upload_Item_Model item) {
    synchronized (this.filteredData) {
        this.filteredData.remove(item);
    }
}

Любая помощь или совет приветствуется!


РЕДАКТИРОВАТЬ + РЕШЕНИЕ

Я получил все, чтобы работать, используя решение Раджата Мехры о том, чтобы использовать один поток для загрузки всех файлов вместо множества потоков для загрузки только одного файла. Я должен был сделать небольшую корректировку, чтобы заставить его работать, но теперь все идет гладко.

public void uploadFile() {

    new Thread() {

        @Override
        public void run() {

            for (int i = 0; i < selectedIndicies.size(); i++) {

                Upload_Item_Model selectedItem = adapter.getFilteredData().get(selectedIndicies.get(i));

                SaveFile file = getFileWithFilename(token, selectedItem.getTitle(), UploadActivity.this);
                FileUploader.upload(file, new FileUploader.FileUploadListener() {

                    @Override
                    public void onFinish() {

                        runOnUiThread(() -> {

                            // I can now simply use the selectedItem here!
                            adapter.removeItem(selectedItem);
                            adapter.notifyDataSetChanged();
                        });
                    }
                });
            }
        }
    }.start();
}

Ответы [ 2 ]

1 голос
/ 06 июня 2019

Вместо создания нескольких потоков создайте одну тему и загрузите в нее все файлы по одному.

public void uploadFile() {


    new Thread() {

        @Override
        public void run() {

            //
            // Uploads the given file, when the upload is complete
            // the onFinish() method is called and the file is passed
            // back so I can update the RecyclerView
            //
            for (int i = 0; i < selectedIndicies.size(); i++) {
                // Get the i-th selected item
                Upload_Item_Model selectedItem = adapter.getFilteredData().get(selectedIndicies.get(i));

                // Get the file associated with the i-th selected item
                SaveFile file = getFileWithFilename(token, selectedItem.getTitle(), UploadActivity.this);
                FileUploader.upload(file, new FileUploader.FileUploadListener() {

                    @Override
                    public void onFinish(SaveFile file) {

                        // Loop through all items in RecyclerView
                        for (Upload_Item_Model item : adapter.getFilteredData()) { // this is line 471 where the crash happens

                            //
                            // If the RecyclerView item has the same name
                            // as the returned file, then it is
                            // the file I just uploaded
                            //

                            if (item.getTitle().equals(file.getFilename())) {
                                runOnUiThread(() -> {

                                    // Removes the item from the adapter
                                    adapter.removeItem(item);
                                    adapter.notifyDataSetChanged();
                                });

                            }
                        }
                    }
                });

            }
        }
    }.start();
}
0 голосов
/ 06 июня 2019

Исключение выдается, когда вы звоните adapter.notifyDataSetChanged();, потому что под капотом notifyDataSetChanged делают что-то с вашими предметами (без синхронизации), и в то же время вы звоните this.filteredData.remove(item);, и это не имеет значения с синхронизированным ключевым словом или без него .

Вероятно, прежде всего вам нужно позвонить всем своим removeItem, а затем позвонить adapter.notifyDataSetChanged(); Вот так:

for (Upload_Item_Model item: adapter.getFilteredData()) {
 if (item.getTitle().equals(file.getFilename())) {
  runOnUiThread(() -> {
   adapter.removeItem(item);
  });

 }
}
adapter.notifyDataSetChanged();

Думать: notifyDataSetChanged() - неэффективный способ обновления элементов просмотра вашего переработчика. Существует DiffUtil.Callback, который проверяет разницу между двумя наборами данных и эффективно отправляет изменения в представление переработчика.

...