tokio

crate

Rustの非同期ランタイム

spawn

let handle: tokio::JoinHandle<T> = tokio::spawn(async move {
  process(socket).await;
});
let result = handle.await?;

• bytes クレート. Arc<Vec<u8>> Vec<u8> に対してshallow copy提供する

Mutex

• 2022-03-10 std::sync::Mutex 握っているときにawaitできないらしい

  • rust - async function: the trait std::marker::Send is not implemented for std::sync::MutexGuard<'_, Client> - Stack Overflow
  • Shared state - Holding a MutexGuard across an .await - 《Tokio v1.0 Tutorial》 - 书栈网 · BookStack

• 状態を共有する｜Tokio チュートリアル (日本語訳)

  • mutex.lock.await は async 境界またげるが重い

• GitHub - Amanieu/parking_lot: Compact and efficient synchronization primitives for Rust. Also provides an API for creating custom synchronization primitives.

channel

• チャネル｜Tokio チュートリアル (日本語訳)

• mpsc: MPSC

• broadcast: multi-producer, multi-consumer

• watch: single-producer, multi-consumer

Stream

• Streams｜Tokio チュートリアル (日本語訳)
  • stream::unfold: Future をまとめるものじゃないのか
    • for_each するには future::FutureExt が必要だった
  • Introduction to gRPC in Rust | Roman Kudryashov’s tech blog