Блог

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

Я создал файл Kotlin с сетевой функцией, которую я планирую вызвать в классе Java (модель представления, которая в настоящее время должна оставаться написанной на Java). Идея заключается в том, что я хочу, чтобы сетевая функция изменила и вернула список обратно в модель представления, а затем позволила модели представления продолжить.

 fun performNetworking(
    data: MutableList<Data>
): MutableList<Data> {
    CoroutineScope(Dispatchers.IO).launch {
        data.forEach {
            // modify each element in the list
        }
    }
    return data
}
 

В настоящее время я вызываю его из модели представления Java как таковой:

     public void modifyData(List<Data> data) {
        List<Data> modifiedData = NetworkingKt.performNetworking(data);
        performMoreThings(modifiedData);
    }
 

При такой реализации performMoreThings() срабатывает так, как будто ни одна из данных в списке не была изменена. Благодаря отладке я обнаружил, что, прежде чем область сопрограммы сможет что-либо сделать, вывод performMoreThings() достигается с помощью списка неизмененных данных.

Поэтому мне интересно, есть ли способ заставить код дождаться завершения работы области сопрограммы, прежде чем возвращать список данных в модель представления Java (без блокировки основного потока и предотвращения взаимодействия пользователя с приложением)? Или я неправильно понимаю возможности, цели и реализации сопрограмм, и это невозможно? Должен ли я передать ссылку на модель представления и заставить ее вызвать метод продолжения после завершения сопрограммы, как я сделал бы с AsyncTask в its onPostExecute() ?

Нет, это невозможно. Не из — за ограничений сопрограмм, а наоборот-из-за ограничений не сопрограммного кода. Ваш modifyData() метод является обычным, не приостанавливаемым, поэтому он все равно не может ждать, не блокируя поток. Приостановить функции Kotlin может сделать это, но методы Java не могут.

Вам нужно либо вызвать modifyData() из фонового потока, чтобы блокировка не была проблемой, либо перепроектировать performNetworking() , чтобы использовать один из классических методов для решения асинхронных задач, т. Е. Получить обратный вызов или вернуть будущее:

 fun performNetworking(
    data: MutableList<Data>
): CompletableFuture<MutableList<Data>> {
    return CoroutineScope(Dispatchers.IO).future {
        data.forEach {
            // modify each element in the list
        }
        data
    }
}
 

 public void modifyData(List<Data> data) {
    NetworkingKt.performNetworking(data)
            .thenAccept(this::performMoreThings);
}