Телеграмм чат группы rust_async страница 1237

parrot.ru

Рейтинг популярных групп и каналов

В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Rust Async

366 membersпожаловаться на группу

2020 July 01

YJ

Yo Jla in Rust Async

Даа.. работает, но нужно изучаить получше)
сейчас ссделаю минимальный пример работающий)

если не сложно, можно работающий потом в playground засунуть и здесь положить?
"утащю в норку".

источник

20:36пожаловаться #1

d

diabolo in Rust Async

когда дергаю cx.waker().wake_by_ref(), я так понимаю, запускаю текущий цикл обработки сообщений и он прощелкивает все poll снова

нет, он просто говорит поместить в пул эту футуру снова

источник

20:37пожаловаться #2

m

mAX in Rust Async

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=d911214fbf09c7ba2b11930be0e65e17

вот тут после того как забрали из потока значение poll_next() и оно не None, то дергаем cx.waker().wake_by_ref()
таким образом наша фьюча повторно дергается и мы забираем следующее значение.. когда придет None, а это будет через 10 значений фьюча повиснет т.к. wake_by_ref не вызывали, событий больше нет и в последний раз вернули Pending

источник

20:40пожаловаться #3

d

diabolo in Rust Async

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=d911214fbf09c7ba2b11930be0e65e17

вот тут после того как забрали из потока значение poll_next() и оно не None, то дергаем cx.waker().wake_by_ref()
таким образом наша фьюча повторно дергается и мы забираем следующее значение.. когда придет None, а это будет через 10 значений фьюча повиснет т.к. wake_by_ref не вызывали, событий больше нет и в последний раз вернули Pending

обязательно зависнет, у тебя нет завершения треда, можешь его завершить через join! или сделать корректное завершение внутри твоего spawn, лучше первое

источник

20:46пожаловаться #4

m

mAX in Rust Async

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=6722cbbbace9cca15228552d127f8446

Добавил еще одну пустую фьючу
она просто Pending возвращает и пишет в консоль что ее дергали
сцепил с первой читалкой rx через join!()
cx.waker().wake_by_ref() вызванный в читалке дергает и пустую тоже

источник

20:47пожаловаться #5

d

diabolo in Rust Async

то есть let h = spawn... join!(h)

источник

20:47пожаловаться #6

m

mAX in Rust Async

обязательно зависнет, у тебя нет завершения треда, можешь его завершить через join! или сделать корректное завершение внутри твоего spawn, лучше первое

это понимаю, я специально описал почему так для себя..

источник

20:47пожаловаться #7

m

mAX in Rust Async

нет, он просто говорит поместить в пул эту футуру снова

вот, получается wake_by_ref дергает все poll во всех фьючах по цепочке? а не одну конкретную ветку перевыполняет

источник

20:48пожаловаться #8

m

mAX in Rust Async

let server_task = Server::new(rx);
let server1_task = Server1{};
futures::join!(server_task, server1_task);

внутри server_task::poll дернули cx.waker().wake_by_ref() и poll выполнился у обоих server_task и server1_task

источник

20:49пожаловаться #9

d

diabolo in Rust Async

вот, получается wake_by_ref дергает все poll во всех фьючах по цепочке? а не одну конкретную ветку перевыполняет

у токио есть замечательная вещь — называется tracer — рекомендую поиграться

источник

20:51пожаловаться #10

m

mAX in Rust Async

Спасибо! Пойду изучать)

источник

20:51пожаловаться #11

d

diabolo in Rust Async

Спасибо! Пойду изучать)

и да, это комманда экзекутору пробежаться по фичам, если бы ты из Server1 вернул Ready, то он бы выполнился один раз. блин как тяжко с телефона (

источник

20:55пожаловаться #12

m

mAX in Rust Async

эх, к сожалению на playground нету extern crate tracing;
очень удобно всякие демки делать.. прикрутили бы уже cargo туда

источник

20:56пожаловаться #13

d

diabolo in Rust Async

эх, к сожалению на playground нету extern crate tracing;
очень удобно всякие демки делать.. прикрутили бы уже cargo туда

туда попадают только те крейты, которые в топе на crates.io сколько мне помнится

источник

20:57пожаловаться #14

2020 July 02

В

Виталий in Rust Async

Всем привет. Подскажите пожалуйста по actix как можно взаимодействовать любой функции рендеринга страницы с актором вебсокета? Пример на их сайте показывает актор вебсокета изолированым. Надо вытащить состояние сокета работает или не работает. А в вебсокет передавать изменнные данные

источник

06:45пожаловаться #15

SD

Sergey Duck in Rust Async

А зачем на Future нужен метод .boxed()? Зачем ее так пинить?

источник

12:03пожаловаться #16

d

diabolo in Rust Async

А зачем на Future нужен метод .boxed()? Зачем ее так пинить?

ну, он больше для склеивания нисклеиваемого, например со старыми футурами

источник

12:23пожаловаться #17

D

Denis in Rust Async

А зачем на Future нужен метод .boxed()? Зачем ее так пинить?

чтобы стирать тип, очевидно

источник

12:27пожаловаться #18

d

diabolo in Rust Async

чтобы стирать тип, очевидно

угу, когда нужно быстро накостылить особо не заморачиваясь)

источник

12:38пожаловаться #19

ph

pl 🦑 hk in Rust Async

необязательно, иногда нужно положить в коллекцию

источник

12:40пожаловаться #20