callback - 如何实现 JavaScript 样式的回调？

Question

我正在尝试实现 JavaScript 样式的回调。我有一个使用库的应用程序(两者都是我的)，我需要应用程序能够将闭包或函数传递给库中的方法，然后在满足条件时生成线程并在线程内部调用回调。

主要.rs

fn main(){
    welcome_message();
    mylib::connect(|| println!("Connected to service! Please enter a command. (hint: help)\n\n"));
    loop {
        match prompt_input() {
            true => {},
            false => break,
        }
    }
}

lib.rs

pub fn connect<F>(resolve: F) -> (mpsc::Sender<Message>, mpsc::Receiver<Message>)
    where F: Fn()
{

    ...

    let receive_loop = Thread::scoped(move || {
        for response in receiver.incoming_messages::<Message>(){
            let json_string = match response.unwrap() {
                Message::Text(txt) => txt,
                _ => "".to_string(),
            };
            let message = json::Json::from_str(json_string.as_slice());
            let message_json = message.unwrap();
            if message_json.is_object() {
                let ref something = receiver_tx;
                let obj = message_json.as_object().unwrap();
                let something_json = obj.get("lsri").unwrap();
                let something = something_json.to_string().replace("\"", "");
                match something.as_slice() {
                    "service#connected" => resolve(),
                    _ => println!("{}", type),
                }
            } else {
                println!("Invalid service response");
            }
        }
    });

    ...

}

错误

src/lib.rs:54:24: 54:38 error: the trait `core::marker::Send` is not implemented for the type `F` [E0277]
src/lib.rs:54     let receive_loop = Thread::scoped(move || {
                                     ^~~~~~~~~~~~~~
src/lib.rs:54:24: 54:38 note: `F` cannot be sent between threads safely
src/lib.rs:54     let receive_loop = Thread::scoped(move || {
                                     ^~~~~~~~~~~~~~

我传递的不一定是闭包，我也可以传递一个函数。它不需要任何参数或返回类型，但如果有帮助，我可以添加一些虚拟的。我非常愿意接受有关实现同一目标的其他方法或方式的建议。

我试过使用:

• 线程::生成
• FnMut()
• Arc::new(resolve)(带有 .clone() 的实现)
• Arc::new(Mutex::new(resolve))(带有 .lock() 的实现)
• 在 Google 中搜索示例
• 完整阅读 Rust 书
• 在错误消息中搜索示例
• 以上所有的各种配置

这对 Rust 来说可能吗？有没有更好的办法？

提前感谢您抽出时间。

解决方案:

对于将来发现此问题的任何人，根据下面答案的说明，我将 connect 的签名更改为以下内容，这允许将回调传递到线程中。

pub fn connect<'a, T, F>(resolve: F) -> (mpsc::Sender<Message>, mpsc::Receiver<Message>)
    where T: Send + 'a, F: FnOnce() -> T, F: Send + 'a

Answer 1

尝试使用与 Thread::scoped 相同的限制标记您的 F :

fn scoped<'a, T, F>(f: F) -> JoinGuard<'a, T> 
    where T: Send + 'a, F: FnOnce() -> T, F: Send + 'a

具体来说，使用 Send 特性绑定(bind)类型应该清除

的即时错误

the trait core::marker::Send is not implemented for the type F