Ct
@c_vld а ты уверен что Handle Sync+Send?
Так то нет, так что если @tapok_satan хочет херачить из других тредов задачи, нихера не прокатит.
Если надо из других потоков, то создаешь future::sync::mpsc::channel, ресивер в тред с ивентлупом, в него из других тредов шлешь задачи.
Receiver — это стрим, че-то типо того будет:
Так то нет, так что если @tapok_satan хочет херачить из других тредов задачи, нихера не прокатит.
Если надо из других потоков, то создаешь future::sync::mpsc::channel, ресивер в тред с ивентлупом, в него из других тредов шлешь задачи.
Receiver — это стрим, че-то типо того будет:
let receiver = ...
let core = Core::new()?;
let handle = core.handle();
let future = receiver.for_each(|task| handle.spawn(process_task_future(task)));
core.run(future)?;
Вообще для этой задачи есть Remote. https://docs.rs/tokio-core/0.1.10/tokio_core/reactor/struct.Core.html#method.remote