rust中的超时处理

自从 tokio 1.0发布以来，rust的异步开发总算大势已定。尽管没达到标准库的速度，依然挡不住大家的热情。看编程排行榜，增加2倍的开发者。
既生瑜何生亮，感觉go就是小号的rust。
 
不废话了。背景：之前用go开发一个边缘网关的小东东，业余时间做了一大半。后来学了rust，打算练手，用rust重新写。
在crate中央仓库里找来找去，选择了 tokio-modbus。测试中发现用rtu的方式下，如果slave没有发回数据，程序将陷入无限等待中。也没找到如何设置这个超时。串口配置中倒是有个超时设置，不知道有啥用。
在tokio-modbus的github上，找到有人提到这个问题。那个解决问题的方式实在是理解不了，也很啰嗦。
自己动手， 用golang和tokio中都有的 select 很好的解决问题。
核心代码如下

1. 1 tokio::select! {
2. 2     result = &ctx.read_holding_registers(3,12) => match result {
3. 3         Ok(v) => println!("Reading holding {:?}", v),
4. 4         Err(_) => println!("reading err"),
5. 5     },
6. 6     _ = tokio::time::sleep(std::time::Duration::from_millis(100)) => println!("reading timeout 100 ms"),
7. 7 }

复制代码

完整的测试代码如下

1. use tokio_modbus::prelude::Reader;
2. use tokio_serial::SerialPortBuilderExt;
4. #[tokio::main]
5. async fn main() -> Result<(), Box<dyn std::error::Error>> {
7.     let mut port = String::from("");
9.     let ports = tokio_serial::available_ports().unwrap();
10.     for p in ports {
12.         port = String::from("com1");
14.         match p.port_type {
15.             tokio_serial::SerialPortType::UsbPort(info) => {
16.                 println!("{}, {:?}", p.port_name, info);
17.                 port = p.port_name;
18.             },
19.             _ => println!("{}, unknown type", p.port_name),
20.         }
22.     }
24.     println!("port is {}", port);
27.     let slave = tokio_modbus::slave::Slave(0x3);
28.     let com = tokio_serial::new(port,9600)
29.         .timeout(std::time::Duration::from_millis(70))
30.         .data_bits(tokio_serial::DataBits::Eight)
31.         .stop_bits(tokio_serial::StopBits::One)
32.         .parity(tokio_serial::Parity::None)
33.         .open_native_async();  // tokio_serial::SerialPortBuilderExt
35.     // let com = tokio_serial::SerialStream::open(&builder).unwrap();
37.     // only open local serial_port
38.     let ctx = tokio_modbus::prelude::rtu::connect_slave(com.unwrap(), slave).await;
40.     let mut ctx = match ctx {
41.         Ok(c) => c,
42.         Err(e) => { println!("err is {}", e); return Ok(())},
43.     };
45.     println!("rtu ctx ok, {:?}", ctx);
47.     let now = std::time::Instant::now();
49.     // let mut timeend = tokio::time::sleep(std::time::Duration::from_millis(100));
50.     tokio::select! {
51.         result = &ctx.read_holding_registers(3,12) => match result {
52.             Ok(v) => println!("Reading holding {:?}", v),
53.             Err(_) => println!("reading err"),
54.         },
55.         _ = tokio::time::sleep(std::time::Duration::from_millis(100)) => println!("reading timeout 100 ms"),
56.     }
58.     println!("elapsed {} millis", now.elapsed().as_millis());
59.     Ok(())
60. }

复制代码

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！