Rez souběžnosti se připojit a tokio

Question 1

Snažím se spustit dvě funkce souběžně s join.

Můj kód je jednoduchý:

tokio = { version = "1.14.0", features = ["full"] }

use tokio::join;
use std::thread::sleep;
use std::time::{Duration, Instant};

async fn fn_1() -> i8 {
  sleep(Duration::from_secs(2));

  2
}

async fn fn_2() -> i8 {
  sleep(Duration::from_secs(2));

  1
}

#[tokio::main]
async fn main() -> () {
  let now = Instant::now();

  println!("start: {:#?}", now.elapsed());

  let a = fn_1();
  let b = fn_2();

  join!(a, b);

  println!("end: {:#?}", now.elapsed());
}

Ale bez ohledu na to, co dělám, to trvá 4s —2s + 2s—, zatímco to by mělo trvat 2s pokud se nepletu:

start: 37ns
end: 4.01036111s

Je tam něco, co mi chybí?

Question 2

Voláte std spánek funkcí, které dal OS vlákno spát, že váš program je spuštěn na. Pokud zavoláte tokio::time::sleep funkce, místo toho, futures by měla být hodnocena současně.

Aby skutečný paralelismus v provedení, budete muset použít tokio::task::spawn nechat runtime rozhodnout, které vlákno spustit plodil budoucnosti.

Pro další čtení na to, co blokuje je, doporučuji tento skvělý blog post: https://ryhl.io/blog/async-what-is-blocking/

sebpuetz · Answer 1 · 2021-11-22T21:16:29

Voláte std spánek funkcí, které dal OS vlákno spát, že váš program je spuštěn na. Pokud zavoláte tokio::time::sleep funkce, místo toho, futures by měla být hodnocena současně.

Aby skutečný paralelismus v provedení, budete muset použít tokio::task::spawn nechat runtime rozhodnout, které vlákno spustit plodil budoucnosti.

Pro další čtení na to, co blokuje je, doporučuji tento skvělý blog post: https://ryhl.io/blog/async-what-is-blocking/

Aha... Takže jakmile se dostaneme do asynchronní s Tokio, musíme se spolehnout na to pro všechny asynchronní práce. Budu se muset podívat na tento odkaz, díky moc.

Rez souběžnosti se připojit a tokio

Otázka

Nejlepší odpověď

V jiných jazycích

Tato stránka je v jiných jazycích

Populární v této kategorii

Oblíbené položky v této kategorii