如何实现 JavaScript 样式的回调？

Question

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

main.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 || {
                                     ^~~~~~~~~~~~~~

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

我尝试过使用：

• 线程::spawn
• 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 trait 来限制类型应该可以清除

特征 core::marker::Send 没有为 F 类型实现