rust - 为什么生成在MPSC channel 上迭代的线程的程序永远不会退出？ [复制]

Question

This question already has an answer here:

Process never exits after successfully receiving from MPSC channel

(1个答案)


3个月前关闭。




我编写了以下程序:

use std::process;
use std::sync::mpsc;
use std::thread;
use std::time::Duration;

fn main() {
    let (tx, rx) = mpsc::channel();
    let t1 = thread::spawn(move || {
        for i in 0..10 {
            if i != 9 {
                let msg = i32::from(i);
                tx.send(msg).unwrap();
            } else {
                println!("Greetings from process {} of 10!", i);
                for received in rx.iter().take(10) {
                    println!("Greetings from process {} of 10!", received);
                    thread::sleep(Duration::from_secs(1));
                }
                process::exit(1);
            }
        }
    });
    t1.join().unwrap();
}

程序永无止境。它执行所有代码，但从未完成。有人可以给我些帮助吗？

最佳答案

问题是 iter() 上的 Receiver 是阻塞调用。因此，由于 Sender 尚未“挂断”，因此它将保持受阻状态，因为您只发送9消息。如果您尝试使用take()或更少的9(即最多发送的内容)，则for循环将按预期结束。
或者，您可以(1)使用 try_iter() ，当没有更多待处理的值时将停止迭代，或者(2)您需要在进入for循环之前“挂断” Sender ，您可以执行此操作通过调用drop(tx)。

} else {
    drop(tx);
//  ^^^^^^^^
    println!("Greetings from process {} of 10!", i);
    for received in rx.iter().take(10) {
        println!("Greetings from process {} of 10!", received);
        thread::sleep(Duration::from_secs(1));
    }
    process::exit(1);
}

或者

} else {
    println!("Greetings from process {} of 10!", i);
    for received in rx.try_iter().take(10) {
//                     ^^^^^^^^
        println!("Greetings from process {} of 10!", received);
        thread::sleep(Duration::from_secs(1));
    }
    process::exit(1);
}

当然，这是在忽略您正在尝试做的事情令人困惑的事实，例如为什么线程要向自身发送/接收。但是，这将解决“不退出”问题。

关于rust - 为什么生成在MPSC channel 上迭代的线程的程序永远不会退出？ [复制]，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/65200536/

上一篇：rust - CSV from_writer可以在stdout()上使用，但不能在from_path上使用

下一篇：string - 声明char以防 rust

Answer 1

问题是 iter() 上的 Receiver 是阻塞调用。因此，由于 Sender 尚未“挂断”，因此它将保持受阻状态，因为您只发送9消息。如果您尝试使用take()或更少的9(即最多发送的内容)，则for循环将按预期结束。
或者，您可以(1)使用 try_iter() ，当没有更多待处理的值时将停止迭代，或者(2)您需要在进入for循环之前“挂断” Sender ，您可以执行此操作通过调用drop(tx)。

} else {
    drop(tx);
//  ^^^^^^^^
    println!("Greetings from process {} of 10!", i);
    for received in rx.iter().take(10) {
        println!("Greetings from process {} of 10!", received);
        thread::sleep(Duration::from_secs(1));
    }
    process::exit(1);
}

或者

} else {
    println!("Greetings from process {} of 10!", i);
    for received in rx.try_iter().take(10) {
//                     ^^^^^^^^
        println!("Greetings from process {} of 10!", received);
        thread::sleep(Duration::from_secs(1));
    }
    process::exit(1);
}

当然，这是在忽略您正在尝试做的事情令人困惑的事实，例如为什么线程要向自身发送/接收。但是，这将解决“不退出”问题。