МТ
Результат скину
В первой после
В второй после
В первой после
e поставил cВ второй после
v цифру 5Size: a a a
2021 June 20
МТ
И этот код полностью валиден btw
⚛R
Ребят, кто-то работал из асинков с mio? С неблокирующими TcpStream'ами и poll'ом?
⚛R
А, простите. Думал хотя бы ссылок на примеры накидаете, и я поизучаю.
Да и вообще, это возможно или нет?
Да и вообще, это возможно или нет?
П
Токио на мио висит, вроде
⚛R
Это обе их разработки, но нет примеров как сделать долгие коннекты, через которые время от времени можно гонять пакеты.
⚛R
Да, примеры есть, но без асинков, и в одном потоке. Такое я уже отлично освоил. Хочется заложить мега-архитектуру сразу, чтобы многопоточно работать.
D
а почему бы в таком случае не взять сразу токио?..
⚛R
Что именно из него? Мы в проекте его и используем.
И у него есть свои стримы. Но как это клеить с долгими коннектами, а не коннект-запрос-ответ-закрыл, вот это задача.
И у него есть свои стримы. Но как это клеить с долгими коннектами, а не коннект-запрос-ответ-закрыл, вот это задача.
D
> что именно из него
готовые async-обёртки для всех примитивов из mio
> Но как это клеить с долгими коннектами
а в чём, собственно, проблема-то? О_о
готовые async-обёртки для всех примитивов из mio
> Но как это клеить с долгими коннектами
а в чём, собственно, проблема-то? О_о
⚛R
Ну вот как хранить пучок TcpStream'ов. Как ожидать на них нужные стейты, как в это всунуть TcpListener.accept(), который производит новые стримы, которые !Send, и так далее?
D
tokio::select! {
stream = listener1.accept() => { .. }
stream = listener2.accept() => { .. }
...
}⚛R
Слишком простой пример. Когда пытаешься реально реализовать, тогда натыкаешься на грабли постоянно.
Я поэтому и спрашиваю, есть какие-то примеры такого? Кто-то такое реализовывал уже?
Кстати, какого типа эти listener1 и listener2 тут должны быть?
Кто ими владеет? Захватывает ли их футура? И т.д.
Я поэтому и спрашиваю, есть какие-то примеры такого? Кто-то такое реализовывал уже?
Кстати, какого типа эти listener1 и listener2 тут должны быть?
Кто ими владеет? Захватывает ли их футура? И т.д.
⚛R
Там нет таких примеров, только основы. За прошлую неделю прочитал два раза.
MB
В данном случае это видимо TcpListener-ы, которые штамупют TcpStream-ы
MB
Если листенеров много, то я бы на каждый спавнил в отдельной таске
ph
В mini redis и листенер, и долгоживущие конекты 🤷♀️