對(duì)于終止和掛起線程，您可以使用通道 .

外部終止

在工作循環(huán)的每次迭代中，我們檢查是否有人通過(guò)渠道通知我們 . 如果是，或者如果通道的另一端超出范圍，我們就會(huì)打破循環(huán) .

use std::io::{self, BufRead};

use std::sync::mpsc::{self, TryRecvError};

use std::thread;

use std::time::Duration;

fn main() {

println!("Press enter to terminate the child thread");

let (tx, rx) = mpsc::channel();

thread::spawn(move || loop {

println!("Working...");

thread::sleep(Duration::from_millis(500));

match rx.try_recv() {

Ok(_) | Err(TryRecvError::Disconnected) => {

println!("Terminating.");

break;

}

Err(TryRecvError::Empty) => {}

}

});

let mut line = String::new();

let stdin = io::stdin();

let _ = stdin.lock().read_line(&mut line);

let _ = tx.send(());

}

暫停和恢復(fù)

我們使用 recv() 暫停線程，直到某些東西到達(dá)通道 . 為了恢復(fù)該線程，您需要通過(guò)該 Channels 發(fā)送內(nèi)容;在這種情況下單位值 () . 如果通道的發(fā)送端被丟棄， recv() 將返回 Err(()) - 我們使用它來(lái)退出循環(huán) .

use std::io::{self, BufRead};

use std::sync::mpsc;

use std::thread;

use std::time::Duration;

fn main() {

println!("Press enter to wake up the child thread");

let (tx, rx) = mpsc::channel();

thread::spawn(move || loop {

println!("Suspending...");

match rx.recv() {

Ok(_) => {

println!("Working...");

thread::sleep(Duration::from_millis(500));

}

Err(_) => {

println!("Terminating.");

break;

}

}

});

let mut line = String::new();

let stdin = io::stdin();

for _ in 0..4 {

let _ = stdin.lock().read_line(&mut line);

let _ = tx.send(());

}

}

其他工具

Channels 是執(zhí)行這些任務(wù)的最簡(jiǎn)單，最自然(IMO)的方式，但不是最有效的方法 . 您可以在std::sync模塊中找到其他并發(fā)原語(yǔ) . 它們屬于比通道更低的級(jí)別，但在特定任務(wù)中可以更有效 .

總結(jié)

以上是生活随笔為你收集整理的java暂停另一个线程_如何从另一个线程终止或暂停Rust线程？的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。