Вопросы с меткой [coroutine]
Coroutine - компонент программы, обобщающий понятие подпрограммы, который дополнительно поддерживает множество точек входа (а не одну, как подпрограмма), остановку и продолжение выполнения с сохранением определённого положения, т.е. не разрушает локальные данные. Данную метку следует применять, когда в коде программы реализуется кооперативная многозадачность, т.е. следующая задача выполняется только после того, как текущая задача явно передаст управление.
71
вопрос
0
голосов
2
ответа
39
показов
SingleFlowEvent в MVI и Compose
есть вот такой пример кода
// Viewmodel
sealed interface Event {
object A : Event
object B : Event
}
private val _event = Channel<Event>(Channel....
0
голосов
1
ответ
17
показов
Android, Kotlin, Timber: Timber перестает вести логи в корутинах
У меня во ViewModel такой код:
Timber.d("generatePDF body")
viewModelScope.launch(Dispatchers.Main) {
Timber.d("generatePDF body 2")
}
Первый лог -> "generatePDF body&...
0
голосов
1
ответ
171
показ
Лучшая практика для создания сервера - корутины или poll / select
коллеги.
Некоторое время писал разное прикладное клиент-серверное ПО на C++. Моя обычная практика (в общих чертах):
создать "серверный" сокет для приема входящих подключений
тем или иным ...
1
голос
1
ответ
196
показов
Stackful и Stackless coroutines
В чём различия двух типов корутин? И какой подход реализуется в Go? (каким типом являются горутины)
0
голосов
1
ответ
84
показа
Coroutine рекурсия не понимаю поведение
У меня Coroutine начинает работать независимо от:
yield return new waitforseconds(filltime)
Всё сразу выполняется:
private IEnumerator FindAndDestroyNearestPieces(int column, int row, MatchedType ...
0
голосов
0
ответов
100
показов
Почему при использовании supervisorScope, CoroutineExceptionHandler не получает ошибку?
Я тестирую всякие примеры касательно exception handling и вот у меня есть очень простой пример
fun main() {
val handler = CoroutineExceptionHandler { coroutineContext, throwable ->
...
0
голосов
0
ответов
128
показов
Почему SupervisorJob отменяте все дочерние корутины когда возникает ошибка?
Есть два типа задач в корутинах:
Job
SupervisorJob
Первый тип предназначен для отмены всех дочерних корутин, как только возникает ошибка в одной из них. Но есть SupervisorJob который предназначен ...
1
голос
1
ответ
157
показов
Не могу запустить процессы concurrent.futures с асинхронной функции
Есть такой код:
import asyncio
from concurrent.futures import ProcessPoolExecutor
async def test1(text: str):
for _ in range(2):
await asyncio.sleep(1)
print(text.upper())
async ...
0
голосов
2
ответа
241
показ
Как вывести данные из объекта корутины?
я изучаю API мобильной игры Clash of Clans (coc.py), и веду своего бота в телеграмме в целях удалённого просмотра профиля человека. Я столкнулся с проблемой вывода данных из объекта корутины при ...
0
голосов
2
ответа
104
показа
Ошибка Suspend functions cannot be made Composable при попытке скачать файл
При попытке скачать файл, получаю ошибку:
Suspend functions cannot be made Composable
Как можно поправить?
@Composable
suspend fun CheckVerMain(): File? {
val context = LocalContext.current
val ...
0
голосов
1
ответ
45
показов
Не работает корутина после деактивации и повторной активации скрипта в Unity3d
столкнулся с проблемой при разработке 2d игры в unity3d. Есть два объекта: солдат и точка его респауна. На солдате висит скрипт, позволяющий стрелять левой и правой кнопками мыши:
using System....
1
голос
1
ответ
152
показа
Как не прерывая Flow вызвать долгую по времени выполнения suspend функцию?
Я пытаюсь разобраться в принципах работы с Kotlin Coroutines. У меня есть список передаваемый через Flow в Viewmodel.
val chatsFlow = chatsChangedFlow.asSharedFlow()
.map {
chatList.map { ...
1
голос
0
ответов
40
показов
Как узнать, какой из Deferred вернул ошибку при использовании awaitAll?
Есть ли способ узнать, какой из Deferred-ов вернул ошибку при использовании awaitAll?
Согласно документации awaitAll,
Awaits for completion of given deferred values without blocking a thread and ...
0
голосов
1
ответ
537
показов
Работа с Task (async/await) из главного потока в Unity
Есть код, который записывает текст в какое-либо поле данных UnityCloud:
public async void WriteTimer(string status)
{
var arguments = new Dictionary<string, object>
{
{ "...
0
голосов
0
ответов
144
показа
как обращаться к базе данных room, в корутине?
suspend fun dblistasinc() = coroutineScope{
launch{
}
}
}
значит есть такой код, как мне в нем сделать обращение к базе данных,
вернее я знаю как сделать обращение к базе но я не ...
0
голосов
1
ответ
41
показ
Не могу отправить ответ пользователю в виде ссылок Telegram
Возникла проблемка, с отправкой пользователю сообщения с несколькими ссылками
Я отдаю результат API
async def get_apart(state):
response = requests.get(
"https://barbara.roa.com/dom/...
0
голосов
0
ответов
62
показа
Как определить, смог ли компилятор оптимизировать выделение памяти под корутину?
Как определить, смог ли компилятор оптимизировать выделение памяти под корутину? Те выделить память во фрейме вызывающей стороны? Я пробовал подсовывать пользовательский аллокатор, который писал ...
0
голосов
1
ответ
82
показа
Как из корутины получить ссылку на instance ViewModel
В приложении, основанном на Compose, есть ViewModel:
class ViewModel(application: Application) : AndroidViewModel(application) {}
.
Из него по нажатию кнопки запускается корутина, оторванная от ...
1
голос
2
ответа
136
показов
Unity Coroutines
Есть корутина:
private IEnumerator StartSearchNewTarget()
{
List<Damagable> targetsDamagable;
do
{
FindDamagableInArea(out targetsDamagable);
yield return new ...
0
голосов
0
ответов
174
показа
Как изменяется размер горутины/от чего зависит размер горутины?
Не могу понять от чего зависит размер горутины. Уже прочитал кучу статей о том, как для нее увеличивается размер стека и тп. Если я правильно понял, то стек может переполниться, если я буду ...
0
голосов
0
ответов
184
показа
Являются ли корутины Котлина решением проблемы с потоками?
Решает ли котлин проблему context switching'а потоков и зачем тогда нам нужен Project Loom(грин треды)? Я примерно полагаю, что корутины котлина - это все-таки примитив асинхронного программирования, ...
1
голос
1
ответ
171
показ
Корутины, как получить InputStream из Flow<List<ByteArray>>?
В общем получаю из Room Flow<List<ByteArray>>, вопрос как преобразовать его в InputStream?
class FlowListInputStream(
private val scope: CoroutineScope,
private val flow: Flow&...
0
голосов
0
ответов
127
показов
http запрос в корутине
Для своих целей я использую khttp, т. к. он подходит под меня. Попробовал сделать запрос - не вышло (вылетало приложение). немного почитав о данной проблеме, я сделал вывод, что мне необходимо сделать ...
0
голосов
1
ответ
986
показов
Kotlin : Как получить данные из CoroutineScope
Есть код корутины:
fun startcoroutin (pegenamber:Int) {
//запуск загрузки json in corotine
job?.cancel()
job = CoroutineScope(Dispatchers.Main).launch {
var jsonlist = LoadJson()....
0
голосов
1
ответ
103
показа
Корутина: cancel() не останавливает корутину
Коррутина не останавливается черзе cancel().
Что я делаю:
захожу во фрагмента. в нем есть кнопка, которая отправляет сетевой запрос. после получения ответа - надо обработать View на основе ответа.
...
0
голосов
1
ответ
313
показов
Асинхронность и Корутины в WinForms C#
Столкнулся с такой проблемой, в юнити для асинхронных действий есть очень удобный инструменты IEnumerator, для C# я нагуглил async, но не понял как этим пользоваться
void Start()
{
StartCoroutine(...
0
голосов
1
ответ
471
показ
Как работает асинхронность в корутинах? Да и вообще многопоточность в целом
Корутины как я понимаю это что-то вроде то как работает многопоточность в одноядерном процессоре, а одноядерный процессор в моем понимании если выполняя какие нибудь процессы последовательно займет ...
0
голосов
1
ответ
124
показа
Кастомный адаптер и корутины
При попытке заполнить ListView с помощью кастомного адаптера получаю пустой список, не могу разобраться в чём ошибка ?
HeroesAdapter.kt
class HeroesAdapter(context: Context, heroes: List<TestHero&...
0
голосов
1
ответ
63
показа
Как запустить аргумент (объект) в DialogFragment, который открывается через coroutines EventChannel?
Мне нужно, чтобы при долгом нажатии на recycler Item возникал диалог в посросом "уверены что удалить ...?" И после нажатия positiveButton объект Spend() удалялся из базы. Не пойму, как ...
0
голосов
1
ответ
199
показов
Группировать данные в flow в kotlin по времени
Возникла у меня тут задача:
Есть поток данных. Довольно плотный: тысячи объектов в секунду.
Его нужно писать в БД, но обрабатывать по одному долго.
Соответственно, нужно собирать некоторое количество ...
4
голоса
0
ответов
171
показ
Как вернуть значение из корутины в c++ 20
Пытаюсь вернуть вектор из корутины, функция func1 успешно возвращает в func вектор из 3 элементов, но я не совсем понимаю для чего нужна функция return_value. При вызове co_return в нее передается тот ...
0
голосов
1
ответ
147
показов
NullReferenceException при запуске корутины
MonoBehaviour - базовый класс в Unity, в котором реализованы все основные функции, методы и обработчики...
Сделаю условный пример:
Есть 2 класса:
// 1 - ый класс:
public class HttpRequest : ...
0
голосов
1
ответ
192
показа
Как добавлять/удалять items в MutableStateFlow(List<Int>) и потом использовать этот List<Int> как аргумент в Dao-запросе? Где у меня ошибка?
У меня в базе 1000 объектов Word поделенных на 17 категорий. Мне нужно чтобы в выпадающем меню пользователь отмечал категории, которые нужно отображать в recyclerView. Для этого в меню item-ы с ...
-1
голос
1
ответ
897
показов
RuntimeWarning: coroutine 'Messageable.send' was never awaited (discord.py)
(Сначала скажу что большАя часть кода скопирована)
import discord
from discord.ext import commands
TOKEN = 'длинный'
bot = commands.Bot(command_prefix='!')
@bot.event
async def on_ready():
print('...
0
голосов
1
ответ
297
показов
После перехода в сцену меню и обратно в сцену игры возникает ошибка Coroutine
У меня проблема с повторным входом в игровую сцену после сцены меню.
При первом запуске все работает нормально, но стоит вернуться в сцену с меню, и обратно в игровую, появляется ошибка:
...
0
голосов
0
ответов
70
показов
Как получить данные из CoroutineScope и вставить во View
Получаю следующее исключение при попытке получить данные через корутины из базы Room
Как можно решить данное исключение?
java.lang.IllegalStateException: tv_pf_email must not be null
Код
fun ...
0
голосов
1
ответ
72
показа
Ошибка Inappropriate blocking method call при http запросе в Kotlin
Изучаю корутины и возник вопрос. Набросал простую функцию для получения данных из сети. Но в Intelij IDEA выделяет желтым URL(url).openConnection() и выводит предупреждение "Inappropriate ...
0
голосов
1
ответ
80
показов
RecyclerView. Проблемы с обновлением списка и исчезновением данных
Прилетают данные из БД. При первом появлении на recycleView отображаются корректно записи (кол-во). При переходе на элемент и возврате на список, количество записей может измениться меньшую сторону. ...
1
голос
0
ответов
70
показов
Литература по корутинам ТС
Подскажите, существует ли на сегодняшний день какая-нибудь полноценная литература по тем самым корутинам, которых еще пока нет в STL, и которые пока вроде как заменяет либа cppcoro? Или только посты ...
1
голос
0
ответов
69
показов
android не заходит в корутину
столкнулся со следующей проблемой: Пытаюсь получить список магазинов, но получаю в ответ null. Судя по дебагу, даже не заходит в корутину в DataAccessStrategy. Аналогичный фрагмент кода в другом месте ...
1
голос
1
ответ
91
показ
Из корутины в Main
Есть метод, который по ссылке возвращает json геокодинг по координатам:
private fun urlRead() {
GlobalScope.launch(Dispatchers.IO) {
val lng = intent.getDoubleExtra(LAT, 0.0)
val ...
0
голосов
0
ответов
99
показов
Перенос логики синхронизации с Kotlin корутин на iOS Swift в связке RxSwift+RxAlamofire
Есть некий функционал синхронизации, который хорошо рализован на корутинах. Код-пример ниже:
class SyncExample {
companion object {
const val TAG = "SyncExample"
val progress: ...
0
голосов
0
ответов
84
показа
Почему g++-10 не может использовать ключевые слова связанные с корутинами, хотя 20 стандарт включен и необходимый флаг выставлен?
Я попытался использовать ключевые слова из с++20 связанные с корутинами, но компилятор выдает ошибку
Std::experimental::coroutine_traits type was not found; include
<experimental/coroutine> ...
1
голос
1
ответ
63
показа
Возможно ли приостановить выполнение функции, а затем из другой функции возобновить выполнение первой?
Архитектура MVVM. Есть некий менеджер в котором выполняется тяжелая функция main()
во время выполнении может оказаться, что нужны дополнительные данные от пользователя, тогда функция сетает LiveData ...
0
голосов
1
ответ
158
показов
как вызвать suspend функцию из Сервиса Андроид?
Обычно фрагменты или вьювмодели дают нам scope,
viewModelScope.launch {
withContext(Dispatchers.IO) {
***suspend...***
}
}
есть ли подобное в Сервисах или как вызвать suspend ...
1
голос
1
ответ
59
показов
Coroutne не перехватывают кастомные исключения
Решил перевести проект с rxjava на coroutne,начал с retrofit
//кофиг ретрофита
mAuthRetrofit = Retrofit.Builder()
.baseUrl(BASE_URL_AUTH)
.client(authClient())
....
0
голосов
1
ответ
772
показа
Как сделать перезарядку персонажа с помощью корутины?
Можете помочь с написанием корутины для перезарядки?
Алгоритм такой:перед выстрелом осуществить проверку булевой переменной,которая отобразит готов ли игрок к выстрелу или нет.Эта переменная должна ...
1
голос
1
ответ
450
показов
Android. Coroutine. Retrofit 2. Handler Error
Подскажите, пожалуйста, хороший материал для изучения, который показывает как правильно обрабатывать исключения в retrofit 2 + coroutine.
scope.launch {
try {
val response : ...
2
голоса
1
ответ
169
показов
Отмена Retrofit Request. Coroutines
К примеру, выполняется какой-либо запрос на сервер с помощью Retrofit 2 и Coroutines. В это время (время выполнения запроса), пользователь смещается на предыдущий фрагмент. С помощью чего можно ...
1
голос
1
ответ
590
показов
GlobalScope | Kotlin | Передача данных между потоками
Есть fragment:
override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
super.onViewCreated(view, savedInstanceState)
val activity = Activity("/team/1261", "https://...