|
|
@ -30,7 +30,7 @@ fn main() { |
|
|
|
let (exit_sender, mut exit_receiver) = futures::channel::oneshot::channel(); |
|
|
|
let (exit_sender, mut exit_receiver) = futures::channel::oneshot::channel(); |
|
|
|
let (mut timer_sender, mut timer_receiver) = futures::channel::mpsc::channel(0); |
|
|
|
let (mut timer_sender, mut timer_receiver) = futures::channel::mpsc::channel(0); |
|
|
|
let executor_thread = std::thread::Builder::new() |
|
|
|
let executor_thread = std::thread::Builder::new() |
|
|
|
.affinity(1) |
|
|
|
.ideal_processor(1) |
|
|
|
.spawn(move || { |
|
|
|
.spawn(move || { |
|
|
|
let mut executor = futures::executor::LocalPool::new(); |
|
|
|
let mut executor = futures::executor::LocalPool::new(); |
|
|
|
|
|
|
|
|
|
|
|