如何关闭 tokio-postgres 连接？

Question

在第一个例子tokio-postgresdocumentation中，有一个例子表明你应该运行数据库连接在一个单独的线程中：

// The connection object performs the actual communication with the database,
// so spawn it off to run on its own.
tokio::spawn(async move {
    if let Err(e) = connection.await {
        eprintln!("connection error: {}", e);
    }
});

如果这样做，之后如何终止该连接？

Answer 1

如果您在 tokio 1，tokio::task::JoinHandle 有一个 abort() 函数可以取消任务，从而断开连接。

let handle = task::spawn(async move {
    if let Err(e) = connection.await {
        eprintln!("connection error: {}", e);
    }
}
handle.abort(); // this kills the task and drops the connection

按原样使用我的代码片段会立即终止任务，因此这可能不是您最终想要的，但是如果您保留 handle 并使用它，例如结合某种关闭侦听器，您应该能够根据需要控制连接。

如何关闭 tokio-postgres 连接？

How can you close a tokio-postgres connection?

postgresql

rust

rust-tokio

tokio-postgres