Сопрограммы, asyn c DiffUtil и несоответствие обнаружена ошибка - PullRequest
Новая
       102

Сопрограммы, asyn c DiffUtil и несоответствие обнаружена ошибка

1 голос
/ 07 февраля 2020

У меня проблемы со сборкой Kotlin Потоки и асинхронность c DiffUtil.

У меня есть эта функция в моем RecyclerView.Adapter, которая вычисляет в потоке вычислений DiffUtil и отправляет обновления в RecyclerView в главном потоке: 

suspend fun updateDataset(newDataset: List<Item>) = withContext(Dispatchers.Default) {
        val diff = DiffUtil.calculateDiff(object : DiffUtil.Callback()
        {
            override fun areItemsTheSame(oldItemPosition: Int, newItemPosition: Int): Boolean
                    = dataset[oldItemPosition].conversation.id == newDataset[newItemPosition].conversation.id

            override fun getOldListSize(): Int = dataset.size
            override fun getNewListSize(): Int = newDataset.size

            override fun areContentsTheSame(oldItemPosition: Int, newItemPosition: Int): Boolean
                    = dataset[oldItemPosition] == newDataset[newItemPosition]
        })

        withContext(Dispatchers.Main) {
            dataset = newDataset // <-- dataset is the Adapter's dataset
            diff.dispatchUpdatesTo(this@ConversationsAdapter)
        }
    }

Я вызываю эту функцию из моего фрагмента следующим образом: 

private fun updateConversationsList(conversations: List<ConversationsAdapter.Item>)
{
    viewLifecycleOwner.lifecycleScope.launch {
        (listConversations.adapter as ConversationsAdapter).updateDataset(conversations)
    }
}

updateConversationsList() вызывается несколько раз в течение очень короткого периода времени, потому что это функция вызывается Kotlin s Flows как Flow<Conversation>.

Теперь, несмотря на все это, я иногда получаю ошибку java.lang.IndexOutOfBoundsException: Inconsistency detected. Invalid view holder adapter positionViewHolder. Чтение этой цепочки Я понимаю, что это проблема с многопоточностью, и я прочитал множество рекомендаций, таких как эта , которые все говорят: поток, который обновляет набор данных адаптера, и поток отправка обновлений в RecyclerView должна быть такой же.

Как вы можете видеть, я уже уважаю это, выполняя: 

withContext(Dispatchers.Main) {
    dataset = newDataset
    diff.dispatchUpdatesTo(this@ConversationsAdapter)
}

Поскольку основной поток и только он выполняет эти две операции, как возможно, что я получаю эту ошибку

1 Ответ

2 голосов
/ 07 февраля 2020

Ваша разница в гонках. Если ваше обновление приходит дважды за короткий промежуток времени, это может произойти: 

Adapter has dataset 1 @Main
Dataset 2 comes
calculateDiff between 1 & 2 @Async
Dataset 3 comes
calculateDiff between 1 & 3 @Async
finished calculating diff between 1 & 2 @ Async
finished calculating diff between 1 & 3 @ Async
Dispatcher main starts handling messages
replace dataset 1 with dataset 2 using 1-2 diff @Main
replace dataset 2 with dataset 3 using 1-3 diff @Main - inconsistency

Альтернативный сценарий - это разница между 1-3 can fini sh до 1-2, но проблема остается той же. Вы должны отменить текущий расчет, когда придет новый, и предотвратить развертывание недопустимых различий, например, сохранить ссылку на задание внутри вашего фрагмента: 

var updateJob : Job? = null

private fun updateConversationsList(conversations: List<ConversationsAdapter.Item>)
{
    updateJob?.cancel()
    updateJob = viewLifecycleOwner.lifecycleScope.launch {
        (listConversations.adapter as ConversationsAdapter).updateDataset(conversations)
    }
}

Если вы отмените его, withContext(Dispatchers.Main) внутренне проверит состояние продолжения и выиграет ' т беги.

...