r
Не могу понять что там внутри
Токио у него внутри: https://crates.io/crates/actix-rt
Size: a a a
2020 March 13
MF
red75prime в tokio, судя по всему, mpsc синхронный, верно?
r
red75prime в tokio, судя по всему, mpsc синхронный, верно?
Нет, конечно. Зачем синхронные каналы в асинхронной библиотеке.
MF
А что тогда значит, что оно в sync модуле?
r
Модуль так называется. "Synchronization primitives for use in asynchronous contexts."
MF
Понял, спасибо
ДК
Выпуск языка программирования Rust 1.42
Опубликован релиз языка системного программирования Rust 1.42, основанного проектом Mozilla. Язык сфокусирован на безопасной работе с памятью, обеспечивает автоматическое управление памятью и предоставляет средства для достижения высокого параллелизма выполнения заданий, при этом обходясь без использования сборщика мусора и runtime.
https://www.opennet.ru/opennews/art.shtml?num=52537
Опубликован релиз языка системного программирования Rust 1.42, основанного проектом Mozilla. Язык сфокусирован на безопасной работе с памятью, обеспечивает автоматическое управление памятью и предоставляет средства для достижения высокого параллелизма выполнения заданий, при этом обходясь без использования сборщика мусора и runtime.
https://www.opennet.ru/opennews/art.shtml?num=52537
ДК
Выпуск языка программирования Rust 1.42
Опубликован релиз языка системного программирования Rust 1.42, основанного проектом Mozilla. Язык сфокусирован на безопасной работе с памятью, обеспечивает автоматическое управление памятью и предоставляет средства для достижения высокого параллелизма выполнения заданий, при этом обходясь без использования сборщика мусора и runtime.
https://www.opennet.ru/opennews/art.shtml?num=52537
Опубликован релиз языка системного программирования Rust 1.42, основанного проектом Mozilla. Язык сфокусирован на безопасной работе с памятью, обеспечивает автоматическое управление памятью и предоставляет средства для достижения высокого параллелизма выполнения заданий, при этом обходясь без использования сборщика мусора и runtime.
https://www.opennet.ru/opennews/art.shtml?num=52537
на opennet, русское')
A
Некий enum без PartialEq, чтобы в тестах вместо assert_eq!(a, MyVariant(b)) писать assert!(matches!(a, MyVariant(B))). Например.
Это же даже длиньше
MF
Подскажите, а как правильно делать sleep в асинхронном цикле, который внутри ожидает сообщений от mpsc-продьюсеров?
MF
И правильно ли вообще так делать
r
async { loop { let msg = rx.await; /* do smth */ } } или я не так понял?MF
ага, это не будет нагружать процессор?
MF
т.е. не нужно ли в этом loop делать “sleep”
MF
если я знаю, что сообщения будут приходить один-два в пару сек
K
await и есть тот самый sleep
r
std::thread::sleep в асинхронном коде не нужен никогда, от слова совсемMF
#[actix_rt::main]
async fn main() -> std::io::Result<()> {
let (producer, mut consumer) = mpsc::unbounded_channel::<String>();
tokio::spawn(move || preloader_logic(consumer));
}
pub async fn preloader_logic(mut consumer: mpsc::UnboundedReceiver<String>) {
loop {
while let Some(task) = consumer.recv().await {
dbg!(task);
}
}
}