blob: a9181f752778b325f5f183fd206583a5ebf1eaa5 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
use std::{io, thread};
use tokio_core::reactor::Core;
/// Creates a new tokio event loop on a new thread, runs the provided `init` closure on the thread
/// and sends back the result.
/// Used to spawn futures on the core in the separate thread and be able to return sendable handles.
pub fn create<F, T>(init: F) -> io::Result<T>
where
F: FnOnce(&mut Core) -> T + Send + 'static,
T: Send + 'static,
{
let (tx, rx) = ::std::sync::mpsc::channel();
thread::spawn(move || match create_core(init) {
Err(e) => tx.send(Err(e)).unwrap(),
Ok((mut core, out)) => {
tx.send(Ok(out)).unwrap();
loop {
core.turn(None);
}
}
});
rx.recv().unwrap()
}
fn create_core<F, T>(init: F) -> io::Result<(Core, T)>
where
F: FnOnce(&mut Core) -> T + Send + 'static,
{
let mut core = Core::new()?;
let out = init(&mut core);
Ok((core, out))
}
|
