1

因此,如果您有一个 MUD 服务器在单独的进程中处理每个 tcp 连接,

for stream in acceptor.incoming() {
    match stream {
        Err(e) => { /* connection failed */ }
        Ok(stream) => spawn(proc() {
            handle_client(stream)
        })
    }
}

为该服务器共享可变世界数据的策略是什么?我可以想象 n 个连接响应来自用户的命令。每个命令都需要访问并可能修改世界。

pub struct Server<'a> {
    world: World<'a>
}

pub struct World<'a> {
    pub chat_rooms: HashMap<&'a str, ChatRoom<'a>>
}


impl<'a> World<'a> {
    pub fn new() -> World<'a> {
        let mut rooms = HashMap::new();
        rooms.insert("General", ChatRoom::new("General"));
        rooms.insert("Help", ChatRoom::new("Help"));
        World{chat_rooms: rooms}
    }
}

Arc会是要走的路吗?

let shared_server = Arc::new(server);
let server = shared_server.clone();

spawn(proc() {
    // Work with server
});

扩展到 100 或 1000 个用户怎么样?我只是在寻找正确方向的推动力。

4

1 回答 1

4

AnArc将允许您从多个任务中访问一个值,但它不允许您可变地借用该值。编译器无法静态验证一次只有一个任务会可变地借用该值,并且在不同任务上同时改变一个值会导致数据竞争。

Rust 的标准库提供了一些允许安全地改变共享对象的类型。这是其中的两个:

  • Mutex: 这是一个简单的互斥锁。AMutex包装了受保护的值,因此访问该值的唯一方法是锁定互斥锁。一次只有一个任务可以访问包装的值。
  • RWLock: 这是读写锁。这种锁允许多个任务同时读取一个值,但写入者必须具有独占访问权限。这与借用检查器的规则基本相同RefCell(除了锁等到借用被释放,而不是编译失败或恐慌)。

您需要将 aMutex或 a包装RWLock在 anArc中以使其可供多个任务访问。

于 2014-11-09T23:34:10.870 回答