如何解决错误“线程'主'在'没有当前反应堆'时恐慌”？

Question

我正在尝试连接到数据库：

extern crate tokio; // 0.2.6, features = ["full"]
extern crate tokio_postgres; // 0.5.1

use futures::executor;
use tokio_postgres::NoTls;

fn main() {
    let fut = async {
        let (client, connection) = match tokio_postgres::connect("actual stuff", NoTls).await {
            Ok((client, connection)) => (client, connection),
            Err(e) => panic!(e),
        };
        tokio::spawn(async move {
            if let Err(e) = connection.await {
                eprintln!("connection error: {}", e);
            }
        });

        let rows = match client
            .query(
                "SELECT $1 FROM planet_osm_point WHERE $1 IS NOT NULL LIMIT 100",
                &[&"name"],
            )
            .await
        {
            Ok(rows) => rows,
            Err(e) => panic!(e),
        };
        let names: &str = rows[0].get("name");
        println!("{:?}", names);
    };
    executor::block_on(fut);
    println!("Hello, world!");
}

它编译了，但是当我运行它时，我收到了错误消息

thread 'main' panicked at 'no current reactor'

Answer 1

当使用许多（但不是全部）Tokio 功能时，您必须使用 Tokio reactor。在您的代码中，您尝试使用由期货箱 (executor::block_on) 提供的通用执行器。使用 Tokio 执行器和反应器通常通过使用 #[tokio::main] 宏来完成：

#[tokio::main]
async fn main() {
    let (client, connection) = match tokio_postgres::connect("actual stuff", NoTls).await {
        Ok((client, connection)) => (client, connection),
        Err(e) => panic!(e),
    };
    tokio::spawn(async move {
        if let Err(e) = connection.await {
            eprintln!("connection error: {}", e);
        }
    });

    let rows = match client
        .query(
            "SELECT $1 FROM planet_osm_point WHERE $1 IS NOT NULL LIMIT 100",
            &[&"name"],
        )
        .await
    {
        Ok(rows) => rows,
        Err(e) => panic!(e),
    };
    let names: &str = rows[0].get("name");
    println!("{:?}", names);
}

the tokio_postgres docs 中的第一个示例甚至向您展示了如何执行此操作：

#[tokio::main] // By default, tokio_postgres uses the tokio crate as its runtime.
async fn main() -> Result<(), Error> {

发生这种情况的一个原因是因为您使用的是tokio::spawn，而has this documented：

如果从 Tokio 运行时外部调用，则会出现紧急情况。

另见：

• How do I synchronously return a value calculated in an asynchronous Future in stable Rust?

---

这不会打印你想要的：

Err(e) => panic!(e),

你想要的

Err(e) => panic!("{}", e),