如何正确退出 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它会被唤醒并产生错误，在这种情况下，我将打破上面的无限和阻塞循环。但是，我如何明确地使用通道的这个属性来做到这一点，而不是求助于其他标志以及try_recv()等等，并且确定性地干净地退出我的线程？

Answer 1

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