让 Rust 线程摆脱阻塞操作的标准方法是什么？-解网

问：

我来自Java，习惯于沿着以下方式的成语

while (true) {
  try {
    someBlockingOperation();
  } catch (InterruptedException e) {
    Thread.currentThread.interrupt(); // re-set the interrupted flag
    cleanup(); // whatever is necessary
    break;
  }
}

据我所知，这适用于整个 JDK 中任何可能阻塞的内容，例如从文件、套接字、队列甚至 .Thread.sleep()

在阅读如何在 Rust 中完成这项工作时，我发现提到了许多看似特殊的解决方案，例如、.我也发现并试图通过发送到线程来获得它，但线程似乎立即死亡而没有留下任何（回溯）痕迹。miotokioErrorKind::InterruptedErrorKindSIGINT

这是我使用的代码（注意：还不是很精通 Rust，所以它可能看起来有点奇怪，但它可以运行）：

use std::io;
use std::io::Read;
use std::thread;

pub fn main() {
    let sub_thread = thread::spawn(|| {
        let mut buffer = [0; 10];
        loop {
            let d = io::stdin().read(&mut buffer);
            println!("{:?}", d);
            let n = d.unwrap();
            if n == 0 {
                break;
            }
            println!("-> {:?}", &buffer[0..n]);
        }
    });

    sub_thread.join().unwrap();
}

通过“阻塞操作”，我的意思是：

睡
套接字 IO
文件 IO
队列 IO（还不确定队列在 Rust 中的位置）

像在 Java 中一样，向线程发出信号，表明是时候收拾行李回家了？Thread.interrupt()

多线程 Rust 终止

use std::{
    sync::{
        atomic::{AtomicBool, Ordering},
        Arc,
    },
    thread,
    time::Duration,
};

fn main() {
    let please_stop = Arc::new(AtomicBool::new(false));

    let t = thread::spawn({
        let should_i_stop = please_stop.clone();
        move || {
            while !should_i_stop.load(Ordering::SeqCst) {
                thread::sleep(Duration::from_millis(100));
                println!("Sleeping");
            }
        }
    });

    thread::sleep(Duration::from_secs(1));
    please_stop.store(true, Ordering::SeqCst);
    t.join().unwrap();
}

睡

据我所知，没有办法打断。文档甚至说：

在 Unix 平台上，由于信号，此函数不会提前返回

插槽 IO

使用 set_nonblocking 等方法将套接字置于非阻塞模式，然后处理 ErrorKind：：WouldBlock。

另请参阅：

文件 IO

实际上，没有一种很好的跨平台方法来执行异步文件 IO。大多数实现都会启动线程池并在那里执行阻塞操作，通过执行非阻塞操作的内容发送数据。

另请参阅：

队列 IO

也许你的意思是像 MPSC 通道这样的东西，在这种情况下，你会使用像 try_recv 这样的工具。

另请参阅：

让 Rust 线程摆脱阻塞操作的标准方法是什么？

What is the standard way to get a Rust thread out of blocking operations?

评论

睡

插槽 IO

文件 IO

队列 IO

评论