小编Bon*_*nov的帖子

我无法理解如何编写封装在一个结构中的并发异步代码。

我不确定如何准确解释这个问题，所以我会尝试用一个例子来解释。

假设我有一个UdpServer结构。该结构有多个与其行为相关的方法（例如handle_datagram，，，deserialize_datagram等）
如果我想让代码并发，我将生成 tokio 任务，这需要提供给它的闭包是静态的，这意味着我无法&self从内部调用这个任务只要&self不是静态的，这意味着我不能调用self.serialize_datagram().

我理解这个问题（不能保证结构会比线程寿命更长），但看不到解决它的正确方法。我知道可以将函数移出 impl，但这对我来说看起来不是一个好的解决方案。
另外，即使我们暂时假设我可以将其视为&self静态，但出于某种原因，这段代码在我看来仍然不正确（我猜不够生锈）。
另一个“解决方案”是采取self: Arc<Self>而不是&self，但这感觉更糟。

所以我假设有一些我不知道的模式。有人可以向我解释一下我应该如何重构整个事情吗？

示例代码：

struct UdpServer {}
impl UdpServer {
    pub async fn run(&self) {
        let socket = UdpSocket::bind(self.addr).await.unwrap();
        loop {
            let mut buf: &mut [u8] = &mut [];
            let (_, _) = socket.recv_from(&mut buf).await.unwrap();

            // I spawn tokio task to enable concurrency
            tokio::spawn(async move {
                // But i can't use …