使用Glommio构建Rust单线程服务器时遇作用域线程本地变量错误

核心原因 #

Glommio的异步网络组件（包括TcpListener）必须依赖当前线程已初始化的Glommio运行时——具体来说，是依赖线程本地存储（TLS）中的事件循环实例来完成IO操作和调度。

当你在LocalExecutor外部调用TcpListener::bind时，当前线程还没有启动Glommio的运行时环境，对应的线程本地事件循环变量从未被set过。哪怕只是创建Listener，其内部逻辑也会尝试关联当前线程的事件循环，此时找不到实例就直接触发了cannot access a scoped thread local variable without calling set first的panic。

你的极简复现代码直接验证了这一点：仅仅创建TcpListener就触发panic，和后续是否使用Executor无关——问题出在创建Listener的瞬间，而非后续的任务调度。

为什么移到executor.run内部就正常？ #

executor.run(async { ... })会启动Glommio的本地执行器，在这个异步闭包内部，Glommio已经完成了当前线程的运行时初始化：自动设置了线程本地的事件循环实例。此时创建TcpListener就能正确关联到对应的事件循环，后续的incoming()等异步操作也能正常被调度。

修正后的代码示例 #

把TcpListener的创建移到executor.run的异步代码块内即可，同时注意Glommio的TcpListener内部已经用Arc封装，无需额外用Rc包裹：

use std::io::Result;
use clap::Parser;
use futures_lite::{AsyncReadExt, AsyncWriteExt, StreamExt};
use glommio::{
    net::{TcpListener, TcpStream},
    prelude::*,
};

async fn handle_connection(mut stream: TcpStream) -> Result<()> {
    let mut buf = [0u8; 1];
    loop {
        let b = stream.read(&mut buf).await?;
        if b == 0 {
            break;
        } else {
            stream.write(&buf).await?;
        }
    }

    Ok(())
}

#[derive(Parser, Debug)]
#[command(author, version, about, long_about = None)]
struct Args {
    #[arg(short, long, default_value_t = 1)]
    cpu: usize,
    #[arg(short, long, default_value = "0.0.0.0:8888")]
    bind_address: String,
}

fn main() -> Result<()> {
    let args = Args::parse();

    let executor = LocalExecutorBuilder::new(Placement::Fixed(args.cpu)).make()?;
    executor.run(async {
        let listener = TcpListener::bind(args.bind_address)?;
        while let Some(stream) = listener.incoming().next().await {
            let stream = stream.unwrap();
            spawn_local(handle_connection(stream)).detach();
        }
    });

    Ok(())
}

额外注意事项 #

• Glommio的所有异步IO组件（TcpListener、TcpStream、UdpSocket等）都必须在Glommio执行器的上下文内创建，也就是executor.run的异步闭包中，或者由spawn_local启动的任务内部。
• 如果需要在多个任务中共享TcpListener，直接调用其clone()方法即可，无需手动用Rc或Arc包裹。

内容的提问来源于stack exchange，提问作者eof