multithreading - SDL2，FnMut和mpsc，发件人不能在线程之间安全共享

我想用sdl2-rs crate 启动一个计时器来执行绘图调用。我想通过做这样的事情来开始它:

extern crate sdl2;

use std::sync::mpsc;

enum Event {
    Draw,
}

fn main() {
    let sdl_context = sdl2::init().unwrap();
    let video_subsystem = sdl_context.video().unwrap();
    video_subsystem.gl_attr().set_context_version(4, 5);
    println!(
        "Current gl version: {:?}",
        video_subsystem.gl_attr().context_version()
    );
    let timer_subsystem = sdl_context.timer().unwrap();

    let window = video_subsystem
        .window("rust-sdl2 demo: Video", 800, 600)
        .position_centered()
        .opengl()
        .build()
        .unwrap();

    let context = window.gl_create_context().unwrap();

    let (tx, rx) = mpsc::channel();
    {
        let timer_tx = tx.clone();
        timer_subsystem.add_timer(
            1000u32 / 120u32,
            Box::new(move || {
                timer_tx.send(Event::Draw);
                1000u32 / 120u32
            }),
        );
    }
}

但是，我收到此错误:

error[E0277]: the trait bound `std::sync::mpsc::Sender<Event>: std::marker::Sync` is not satisfied in `[closure@src/main.rs:33:22: 36:14 timer_tx:std::sync::mpsc::Sender<Event>]`
  --> src/main.rs:33:13
   |
33 | /             Box::new(move || {
34 | |                 timer_tx.send(Event::Draw);
35 | |                 1000u32 / 120u32
36 | |             }),
   | |______________^ `std::sync::mpsc::Sender<Event>` cannot be shared between threads safely
   |
   = help: within `[closure@src/main.rs:33:22: 36:14 timer_tx:std::sync::mpsc::Sender<Event>]`, the trait `std::marker::Sync` is not implemented for `std::sync::mpsc::Sender<Event>`
   = note: required because it appears within the type `[closure@src/main.rs:33:22: 36:14 timer_tx:std::sync::mpsc::Sender<Event>]`
   = note: required for the cast to the object type `std::ops::FnMut() -> u32 + std::marker::Sync`

我知道发件人不是Sync，所以我将其克隆并将克隆的对象移到FnMut闭包中，但无论如何它都无法正常工作。我怎样才能做到这一点？据我了解，通过将对象移动到闭包中，我们不共享它，因此它必须以这种方式工作。此外，文档中的示例也是如此。

最佳答案

克隆的发件人与原始发件人具有相同的类型，因此它仍然不是Sync。 add_timer函数需要一个封闭的Sync，因此您需要将发送方包装在Mutex中，这使您的发送方可以安全地在线程之间共享。

let timer_tx = Mutex::new(tx.clone());
timer_subsystem.add_timer(
    1000u32 / 120u32,
    Box::new(move || {
        timer_tx.lock().unwrap().send(Event::Draw);
        1000u32 / 120u32
    }),
);

关于multithreading - SDL2，FnMut和mpsc，发件人不能在线程之间安全共享，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/45903158/