AN
Всё оранжевое - это
CoroutineScheduler$Worker.parkДля того, чтобы поток переиспользовался, он должен быть свободен в момент старта таски. Вероятность этого маленькая
withContext(IO)Size: a a a
2020 May 20
AN
Там ровно 3 что-то делающих корутины запущенно в
И они внутри ничего не плодят?
VP
И они внутри ничего не плодят?
Нет. Одна блокируется на чтение, другая читает из канала и блокируется на записи, третья - то же самое, только наоборот. Три цикла и больше ничего.
AN
Нет. Одна блокируется на чтение, другая читает из канала и блокируется на записи, третья - то же самое, только наоборот. Три цикла и больше ничего.
Так каждое чтение/запись - это новая корутина. Нет?
BP
Такое поведение
По каким вообще правилам выделяются новые потоки и когда они останавливаются? Где-нибудь об этом можно почитать?
Dispatchers.IO - это норма? У меня 3 блокирующих задачи, и такое ощущение, что они прыгают между потоками, периодически создавая новые. При этом большая часть потоков ничего не делает.По каким вообще правилам выделяются новые потоки и когда они останавливаются? Где-нибудь об этом можно почитать?
А потоки со временем добавлялись или они сразу выделись 🤔
VP
Так каждое чтение/запись - это новая корутина. Нет?
Нет, всё последовательно
AN
Нет, всё последовательно
Если там несколько потоков, то уже не последовательно.
i
Не сомневаюсь. Но в означенной статье Елизарова все довольно концептуально показано.
а можно еще раз ссылку, пожалуйста, а то из конфы 404 была
VP
А потоки со временем добавлялись или они сразу выделись 🤔
Трудно сказать, не ставил точку останова. Но во время выполнения периодически запускались новые.
AN
BP
Нет, всё последовательно
Чтения из канала разве не саспенд (я толком с ними не работал)
AN
Чтения из канала разве не саспенд (я толком с ними не работал)
да
VP
Чтения из канала разве не саспенд (я толком с ними не работал)
Да, ну так одновременно только одна операция выполняется
AN
Я и говорю, что оно на send суспендится и ищет новый поток на блокирующий вызов
VP
То есть либо корутина спит, ожидая что-то в канале, либо пишет его содержимое в поток
VP
Я и говорю, что оно на send суспендится и ищет новый поток на блокирующий вызов
Логично, но при этом точно известно, что почти все потоки свободны. Откуда/зачем новые - непонятно?
DZ
где-то в августе-сентябре была какая-то фигня с кторовским сокетом... aSocket(ActorSelectorManager(Dispatchers.IO)).tcp().connect()
каждый новый коннект плодил новые потоки при наличии десятка свободных... некоторые бокировались навсегда...
где-то там около октября обновились корутины и эта фигня прекратилась
каждый новый коннект плодил новые потоки при наличии десятка свободных... некоторые бокировались навсегда...
где-то там около октября обновились корутины и эта фигня прекратилась
VP
Такое поведение
По каким вообще правилам выделяются новые потоки и когда они останавливаются? Где-нибудь об этом можно почитать?
Dispatchers.IO - это норма? У меня 3 блокирующих задачи, и такое ощущение, что они прыгают между потоками, периодически создавая новые. При этом большая часть потоков ничего не делает.По каким вообще правилам выделяются новые потоки и когда они останавливаются? Где-нибудь об этом можно почитать?
Похоже, все ответы в доке
"Scheduler consists of corePoolSize worker threads to execute CPU-bound tasks and up to maxPoolSize lazily created threads to execute blocking tasks."
corePoolSize - 8+2 = 10, плюс один поток всегда заблокирован.
CoroutineScheduler:"Scheduler consists of corePoolSize worker threads to execute CPU-bound tasks and up to maxPoolSize lazily created threads to execute blocking tasks."
corePoolSize - 8+2 = 10, плюс один поток всегда заблокирован.
VP
И keepAlive у потоков - 60 сек по дефолту. Однако, не мало.