Несколько push-сообщений: содержимое адаптера изменилось, но ListView не получил уведомление

Когда я получаю много push-сообщений (пусть говорят 50) из GCM в течение 1 секунды, я получаю следующее исключение:

Я уже пытался это исправить, положив BOTH messages.add() и notifyDataSetChanged() внутри runOnUIThread. Я предполагаю, что это происходит, потому что onUpdate() моего слушателя вызывается для каждого push-сообщения. Но не следует ли решить эту проблему с помощью runOnUIThread(), потому что все выполняется последовательно?

РЕДАКТИРОВАТЬ: Я, вероятно, пропустил очень важную часть кода, который я забыл сам:

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

Ответы

Ответ 1

Прежде всего, рассмотрим код в ListView, который выдает это исключение:

@Override
protected void layoutChildren() {
    // ... code omitted...

        // Handle the empty set by removing all views that are visible
        // and calling it a day
        if (mItemCount == 0) {
            resetList();
            invokeOnItemScrollListener();
            return;
        } else if (mItemCount != mAdapter.getCount()) {
            throw new IllegalStateException("The content of the adapter has changed but "
                    + "ListView did not receive a notification. Make sure the content of "
                    + "your adapter is not modified from a background thread, but only from "
                    + "the UI thread. Make sure your adapter calls notifyDataSetChanged() "
                    + "when its content changes. [in ListView(" + getId() + ", " + getClass()
                    + ") with Adapter(" + mAdapter.getClass() + ")]");
        }
    // ... code omitted...
}

[вы могли заметить, что сообщение отличается, но это только потому, что вы используете старый Android - сообщение было более информативным в сентябре `13]

Посмотрим, где объявлена переменная-член mItemCount... Хм, эта переменная кажется наследуемой полностью из класса AdapterView. Хорошо, давайте найдем все назначения во всех классах:

В принципе, за исключением одного присваивания 0 (который находится в методе onIvalidated() и может быть проигнорирован), эта переменная всегда назначается значению Adapter getCount().

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

Теперь, из вашего вопроса, похоже, что вы подозреваете, что существует какая-то "перегрузка" обновлений в потоке пользовательского интерфейса, потому что слишком много сообщений... Однако имейте в виду, что код Runnable.run() который вы отправляете в поток пользовательского интерфейса для выполнения, выполняется атомарно - каждый Runnable выталкивается из очереди событий потока пользовательского интерфейса и запускается до завершения, прежде чем какое-либо другое событие получит возможность обработки.

Вышеизложенное означает, что messages будет обновляться новыми данными, а messageAdapter будет обрабатывать изменения немедленно, и никакое другое событие не может помешать этому потоку (пока messages.add() и messages.addAll() в вашем коде являются синхронными вызовами). Итог: код, который отправляет Runnables в поток пользовательского интерфейса, выглядит отлично, и маловероятно, что он является источником проблемы. Кроме того, трассировка стека исключения не содержит ссылок на Adapter.

До сих пор мы обобщали факты. Начните догадки.

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

Я предполагаю, что messages является той же структурой данных, что и messageAdapter. Возможно, вы изменили messages в какой-то другой части кода, который не работает в потоке пользовательского интерфейса. В этом случае эта модификация может произойти, когда ListView обновляется в потоке пользовательского интерфейса и приводит к исключению [обычно это плохая практика для "утечки" Adapter структуры данных за пределами объекта Adapter].
Аналогичным образом, вы можете случайно манипулировать messageAdapter в других частях кода, который не работает в потоке пользовательского интерфейса.
Возможно, вы отправляете события в поток пользовательского интерфейса, а ListView еще не завершили свою инициализацию. Я почти не верю, что это так, но для того, чтобы быть в безопасности, я предлагаю вам убедиться, что вы зарегистрируете своих слушателей в onResume() и отмените регистрацию в onPause()

EDIT:

На основе кода вашего Fragment я вижу две возможные причины исключения:

Если методы из CustomResponseHandler вы перейдете к ServerUtil.post(), будут вызваны из фоновых потоков, тогда может произойти тот факт, что вы удаляете объект из messages в onFailure().
Как я и предложил - зарегистрировать слушателей в onResume() и отменить регистрацию в onPause() - это может быть не важно для прослушивателей кнопок, но это вызывает утечку памяти при передаче этих слушателей объекту Application. У вас есть утечка памяти в коде.

Если ни одно из вышеперечисленных действий не помогает, отправьте код messageAdapter и MessageDatabase

Ответ 2

Создайте экземпляр адаптера один раз при запуске действия или фрагментируйте что-то вроде этого:

messageAdapter = новый MessageAdapter (getActivity(), R.layout.list_message_item, сообщения); listView.setAdapter(messageAdapter);

Затем напишите свой класс адаптера сообщений

Класс адаптера сообщений:

private ArrayList<Message> mMessageList;

 // constructor
MessageAdapter(Activity activity,int layoutId, ArrayList<Message> messageList){

..
  updateMessageList(messageList);

}
public void updateMessageList(ArrayList<Message> newMessageList){

      // if First time this method is called then 
      if(mMessageList==null){
         mMessageList=new ArrayList<Message>();
      } 

      //Add new messages to message list
      if(null!=newMessageList && newMessageList.size()>0){

         //add new messages
          mMessageList.addAll(newMessageList);

          //Sort you message list
           Collections.sort(mMessageList);
      }
      //update list
      notifyDataSetChanged();

}
.....
end adapter class

Теперь из класса "Класс активности" или "Фрагмент" Вы можете использовать обработчик, поскольку он действует как мост между двумя потоками (пользовательский интерфейс к фону thread также) что-то вроде этого.

      //local message list declaration
       messages=new ArrayList<Message>();
      //Declare handler as a Class member variable 
       Handler globalhandler=new Handler() {
        @Override
        public void handleMessage(Message msg) {
            if (msg.what == "Some identifier string") {

               // after 50 messages are collected it sends one update
    //request after one second to list adapter
                   messageAdapter.updateMessageList(messages);

    // you can also fetch messages from db and update list by calling messageAdapter.updateMessageList(messages); method

                }

             }
           }


app.setOnRoomUserUpdateListener(new OnRoomUserUpdateListener() {
    @Override
    public void onUpdate(final User user, final int roomID, final int joinStatus) {

           final String message;
    if (joinStatus == OnRoomUserUpdateListener.USER_JOINED) {
        message = context.getString(R.string.join_room_message, user.getUsername());
    } else {
        message = context.getString(R.string.leave_room_message, user.getUsername());
    }
          messages.add(new Message(-1, user, message, System.currentTimeMillis(), System
                        .currentTimeMillis(), false, roomID, 0, true, Message.TYPE_JOINLEAVE));           


        //post via handler you can also send a delayed update(like 1 second) since you are receiving 50 messages in a second.
        globalhandler.removeMessages("Some identifier string");
        globalhandler.sendEmptyMessageDelayed("Some identifier string", 1000);
});

Надеюсь, это ответит на ваш вопрос.