帮助

死锁问题

提示

hyperlane 框架推荐不要去显示持有锁，通过 controller_data 的 get 和 set 方法基本满足日常开发使用

提示

hyperlane 框架为了保证数据在多线程之间安全并发访问，使用 tokio 提供的读写锁，需要注意在代码中获取了写锁， 如果此锁没有释放，后面重复获取锁会导致死锁，下面举一个简单的示例: 此代码会导致死锁，原因是先通过 get_write_lock 获取到写锁， 但是此锁在离开 test_middleware 作用域后才会释放，后续再通过 get_socket_addr 获取读锁就会导致死锁

async fn test_middleware(controller_data: ControllerData) {
    let mut controller_data_write_lock: RwLockWriteControllerData =
        controller_data.get_write_lock().await;
    let response: &mut Response = controller_data_write_lock.get_mut_response();
    let socket_addr: String = controller_data_write_lock.get_socket_addr()
        .await
        .unwrap_or_default();
    response
        .set_header(SERVER, "hyperlane")
        .set_header(CONNECTION, CONNECTION_KEEP_ALIVE)
        .set_header("SocketAddr", socket_addr);
}

提示

修改后的代码: 此代码先获取读锁并释放了该锁（ get_socket_addr 完成即释放读锁），后续可以继续获取写锁

async fn test_middleware(controller_data: ControllerData) {
    let socket_addr: String = controller_data.get_socket_addr()
        .await
        .unwrap_or_default();
    let mut controller_data_write_lock: RwLockWriteControllerData =
        arc_lock_controller_dataget_write_lock.get_write_lock().await;
    let response: &mut Response = controller_data_write_lock.get_mut_response();
    response
        .set_header(SERVER, "hyperlane")
        .set_header(CONNECTION, CONNECTION_KEEP_ALIVE)
        .set_header("SocketAddr", socket_addr);
}

异步

提示

由于 hyperlane 框架本身涉及到锁的数据均采取 tokio中的实现，所以涉及到锁的方法调用均需要 await