rust - 如何正确退出 mpsc::Receiver 上的线程阻塞

Question

impl A {
    fn new() -> (A, std::sync::mpsc::Receiver<Data>) {
        let (sender, receiver) = std::sync::mpsc::channel();

        let objA = A { sender: sender, }; // A spawns threads, clones and uses sender etc
        (objA, receiver)
    }
}

impl B {
    fn new() -> B {
        let (objA, receiver) = A::new();

        B {
            a: objA,
            join_handle: Some(std::thread::spwan(move || {
                loop {
                    match receiver.recv() {
                        Ok(data) => /* Do Something, inform main thread etc */,
                        Err(_) => break,
                    }
                }
            })),
        }
    }
}

impl Drop for B {
    fn drop(&mut self) {
        // Want to do something like "sender.close()/receiver.close()" etc so that the following
        // thread joins. But there is no such function. How do i break the following thread ?
        self.join_handle().take().unwrap().join().unwrap();
    }
}

有没有办法在这种情况下干净退出？问题是，当接收者或发送者中的任何一个被丢弃时，另一个嗅探这个并给出错误。在 receiver 的情况下，它将被唤醒并产生一个错误，在这种情况下，我正在打破上面的无限和阻塞循环。但是，我如何明确地使用 channel 的这个属性，而不求助于与 try_recv() 等结合的其他标志，并确定地干净地退出我的线程？

Answer 1

为什么不发送特定消息来关闭此线程？我不知道你的数据是什么，但大多数时候它可能是一个枚举，并在你的接收中添加一个枚举变体，如“MyData::Shutdown”，你可以简单地跳出循环。