advance-practice/select

[giscus[bot]]

advance-practice/select

https://course.rs/advance-practice/select.html

[sdwannfv]

use tokio::sync::oneshot;

#[tokio::main]
async fn main() {
    let (tx1, rx1) = oneshot::channel();
    let (tx2, rx2) = oneshot::channel();

    tokio::spawn(async {
        let _ = tx1.send("one");
    });

    tokio::spawn(async {
        let _ = tx2.send("two");
    });

    tokio::select! {
        val = rx1 => {
            println!("rx1 completed first with {:?}", val);
        }
        val = rx2 => {
            println!("rx2 completed first with {:?}", val);
        }
    }
    // 任何一个 select 分支结束后，都会继续执行接下来的代码
}

这段代码async 没有move 为什么能使用，tx1, tx2的生命周期不是比async代码段短吗？

[sdwannfv]

use tokio::sync::mpsc;

#[tokio::main]
async fn main() {
    let (tx1, mut rx1) = mpsc::channel(10);
    let (tx2, mut rx2) = mpsc::channel(10);

    tokio::spawn(async move {
        let _ = tx1.send("one");
    });

    tokio::spawn(async move {
        let _ = tx2.send("two");
    });

    tokio::select! {
        val = rx1.recv() => {
            println!("rx1 completed first with {:?}", val);
        }
        val = rx2.recv() => {
            println!("rx2 completed first with {:?}", val);
        }
    }

    // 任何一个 select 分支结束后，都会继续执行接下来的代码
}

换成mspc就需要move?

[mayfly227]

Future 可能会在线程间被移动，因此 async 语句块中的变量必须要能在线程间传递.
onehshop实现了Send特征，可以安全的在线程间移动，所以不用move。
而mspc没有实现Send特征，不能安全的在线程间移动，所以必需使用move转换所有权。

[sdwannfv]

应该不是这样的，我理解是，
mpsc::Sender::send(&self, value: T) 使用是Sender的引用，不使用move不会取得Sender的所有权，
而oneshot::Sender::send(mut self, t: T)使用是self不是引用，不使用move也会以取得Sender的所有权，

[mayfly227]

应该不是这样的，我理解是， mpsc::Sender::send(&self, value: T) 使用是Sender的引用，不使用move不会取得Sender的所有权， 而oneshot::Sender::send(mut self, t: T)使用是self不是引用，不使用move也会以取得Sender的所有权，

你说得对，我理解错了，我刚刚测试了。

[horsefaced]

真是要再次吐槽 Pin, 一个 !Unpin 的已经在语言层面 pin 住的东西, 要变成 unpin 居然要使用 Pin.

[bxb100]

友情提醒 std::thread::sleep 是真的会堵塞线程, 使用 tokio::time::sleep 才不会堵塞 tokio 的运行时