Rust MPSC频道在接收器处阻塞

看看这里的这个循环:

while let Some(hw) = rc.recv().await {

recv只会在丢弃发送方、挂断通道时返回None.发送者在AN Arc中，因此当所有Arc都被丢弃时，它将被丢弃.

student期货中有10个Arc，当每一个Arc结束时，它们都会被抛出.他们没有什么可以等待的，所以这种情况发生得很快.然而，还剩下Arc美元.直到main结束时，ch_arc才被丢弃，这发生在呼叫teacher之后.因此，ch_arc永远不会被丢弃.

您可以通过手动删除ch_arc来修复此问题:

#[tokio::main]
async fn main() {
    let (tx, rc): (mpsc::Sender<String>, mpsc::Receiver<String>) = mpsc::channel(100);
    let ch_arc: Arc<mpsc::Sender<String>> = Arc::new(tx);

    for i in 0..10 {
        tokio::task::spawn(student(i, ch_arc.clone()));
    }

    drop(ch_arc);

    let hws = teacher(rc).await;
    println!("{:?}", hws);
}

或者把ch_arc块钱放进一个街区.此块返回rc，因为您稍后需要使用rc.

#[tokio::main]
async fn main() {
    let rc = {
        let (tx, rc): (mpsc::Sender<String>, mpsc::Receiver<String>) = mpsc::channel(100);
        let ch_arc: Arc<mpsc::Sender<String>> = Arc::new(tx);

        for i in 0..10 {
            tokio::task::spawn(student(i, ch_arc.clone()));
        }
        rc
    };

    let hws = teacher(rc).await;
    println!("{:?}", hws);
}