@C_vld а ты уверен что Handle Sync+Send? Так то нет, так

Question

@C_vld а ты уверен что Handle Sync+Send? Так то нет, так

что если @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)?;

#backend #embedded #programming #russian #rust

0

26.11.2017

1 ответов

2 просмотра

Cuno zos Galvus · Accepted Answer

Cuno zos Galvus

Вообще для этой задачи есть Remote. https://docs.rs/tokio-core/0.1.10/tokio_core/reactor/struct.Core.html#method.remote

0

26.11.2017

172 похожих чатов

@C_vld а ты уверен что Handle Sync+Send? Так то нет, так

1 ответов

Похожие вопросы