¯
а. oneshot - один выстрел
Size: a a a
2020 August 23
2020 August 24
KK
А это нормально, что tokio создаёт кучу тредов в actix-web (наверное по треду на каждый конект)? Мне казалось что в асинхронке как раз должно в основном всё работать в небольшом числе тредов. И то преимущественно треды должны использоваться для блокирующих операций.
2020 August 25
A
дык вроде в актиксе создаются треды по колличеству физических ядер в машинке, а потом реиспользует их, но всегда можно задать их колличество
A
или вы о чем то другом?
KK
Да, в актиксе можно указать число воркеров. Я указал 2 и у меня реально 2 треда с именем актикс воркера. А во время нагрузки появляется куча тредов с именем tokio. Когда нагрузка уходит - треды от токио постепенно исчезают.
K
Да, в актиксе можно указать число воркеров. Я указал 2 и у меня реально 2 треда с именем актикс воркера. А во время нагрузки появляется куча тредов с именем tokio. Когда нагрузка уходит - треды от токио постепенно исчезают.
Ты используешь какие-то блокирующие операции?
KK
Я сам не использую. У меня пока что простой прототип прокси, которая на запрос клиента, с помощью крейта rusoto_s3, читает объект из S3 (стримом) и возвращает его клиенту в ответе.
KK
Разве что внутри rusoto есть что-то блокирующее, но снаружи он весь такой async/await
К
Может, кто-нибудь сталкивался...
tokio::spawn() возвращает JoinHandle<T>. Как можно проверять, выполнилась ли таска? JoinHandle<T> реализует Future, но чтобы его poll-ить, нужен контекст с Waker. Где это всё брать?
tokio::spawn() возвращает JoinHandle<T>. Как можно проверять, выполнилась ли таска? JoinHandle<T> реализует Future, но чтобы его poll-ить, нужен контекст с Waker. Где это всё брать?
A
Ну можете канал сообщения туда пихнуть и слушать его, а в таске в этот канал пушнуть событие по завершению)
A
Ну или просто .await добаыить к спавну
MB
Кирилл
Может, кто-нибудь сталкивался...
tokio::spawn() возвращает JoinHandle<T>. Как можно проверять, выполнилась ли таска? JoinHandle<T> реализует Future, но чтобы его poll-ить, нужен контекст с Waker. Где это всё брать?
tokio::spawn() возвращает JoinHandle<T>. Как можно проверять, выполнилась ли таска? JoinHandle<T> реализует Future, но чтобы его poll-ить, нужен контекст с Waker. Где это всё брать?
Нужно просто проверить, выполнилась или нет?
К
Нужно просто проверить, выполнилась или нет?
Да
MB
Кирилл
Да
Тогда можешь вызвать poll с каким-нибудь фейковым контекстом.
К
Adv0cat
Ну можете канал сообщения туда пихнуть и слушать его, а в таске в этот канал пушнуть событие по завершению)
Хочу подождать секунду и проверить, напремер. До конца ждать не хочу.
MB
Например futures_util дает функцию null_waker_ref
MB
Кирилл
Хочу подождать секунду и проверить, напремер. До конца ждать не хочу.
А вот если ты хочешь секунду подождать, то сделай select! из JoinHandle и Delay
К
Например futures_util дает функцию null_waker_ref
О, за это спасибо. То что искал.
К
А вот если ты хочешь секунду подождать, то сделай select! из JoinHandle и Delay
Delay для примера. Мне именно семантика poll-а нужна.
2020 August 26
