0

我正在尝试用 写一个tcp服务器async-std，为了解决读写借用检查的问题，我发现了一个奇怪的方法：

use async_std::prelude::*;
use async_std::task;
use async_std::net::TcpListener;
use async_std::io::BufReader;
fn main() {
    task::block_on(async {
        let listener = TcpListener::bind("0.0.0.0:9000").await.unwrap();
        let mut incoming = listener.incoming();
        while let Some(stream) = incoming.next().await {
            let stream = stream.unwrap();
            println!("Client Addr: {:?}", stream.peer_addr().unwrap());
            task::spawn( async move {
                let (reader, mut writer) = (&stream, &stream); // Stange here <-----
                let reader = BufReader::new(reader);
                let mut lines = reader.lines();
                while let Some(line) = lines.next().await {
                    let mut line = line.unwrap();
                    line.push('x');
                    line.push('\n');
                    writer.write_all(line.as_bytes()).await.unwrap();
                }
            });
        }
    });
}

奇怪： let (reader, mut writer) = (&stream, &stream); // Stange here <----- 我按照这个方法写了一个验证程序：

fn main() {
    let mut arr = vec![1, 2, 3, 4];
    let (r, mut w) = (&arr, &arr);
    for v in r.iter() {
        if v == &2 {
            w.push(5);
        }
    }
    dbg!(arr);
}

得到错误：

error[E0596]: cannot borrow `*w` as mutable, as it is behind a `&` reference

谁能解释一下？

4

1 回答 1

1

这是有效的，因为 TcpStream 具有以下 impls：

impl Read for TcpStream
impl Write for TcpStream
impl<'_> Read for &'_ TcpStream
impl<'_> Write for &'_ TcpStream

前两个是“正常”的，后两个是“特殊”的，允许您执行此读写器技巧。

例如：read()trait 方法定义如下：

pub fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> ImplFuture<Result<usize>>

当你这样做时stream.read(buf)，你正在使用impl Read for TcpStreamimpl。因此，您调用的self是 type的方法&mut TcpStream。

当你这样做时let reader = &stream; reader.read(buf)，你正在使用impl<'_> Read for &'_ TcpStream. 因此，您调用的self是 type的方法&mut &TcpStream。

于 2020-12-20T00:02:39.403 回答