Есть ли способ запустить Tokio :: Delay в новом потоке, чтобы продолжить основной цикл? - PullRequest
Новая
       30

Есть ли способ запустить Tokio :: Delay в новом потоке, чтобы продолжить основной цикл?

0 голосов
/ 20 января 2019

Я пытаюсь запустить функцию в конце задержки, если таймер не отменен. Вариант использования - нажатие и удержание / двойное касание для ввода пользователя.

Основная проблема, с которой я сталкиваюсь, заключается в том, что tokio::run(task); останавливает выполнение основного цикла, что мешает мне оценить состояние контроля пользователей. 

fn start_timer(&self) {
    let function_name = self.combo.function_name.clone();
    let when = Instant::now() + Duration::from_millis(self.combo.timer_value as u64);
    let task = Delay::new(when)
        .and_then(move |_| {
            call_function(&function_name, InteropParams::Button);
            Ok(())
        })
        .map_err(|e| panic!("delay errored; err={:?}", e));

    tokio::run(task);
}

1 Ответ

0 голосов
/ 20 января 2019

Да, вы можете запустить новый поток уровня ОС и запустить цикл событий Tokio: 

use futures::future::Future; // 0.1.25
use std::{
    thread,
    time::{Duration, Instant},
};
use tokio::timer::Delay; // 0.1.14 

fn main() {
    let t = thread::spawn(|| {
        let when = Instant::now() + Duration::from_millis(100);
        let task = Delay::new(when)
            .and_then(move |_| {
                println!("Delay expired");
                Ok(())
            })
            .map_err(|e| panic!("delay errored: {}", e));

        tokio::run(task);
    });

    t.join().unwrap();
}

Вы также можете использовать задачи Токио через tokio::spawn: 

use futures::future::{self, Future}; // 0.1.25
use std::time::{Duration, Instant};
use tokio::timer::Delay; // 0.1.14

fn main() {
    tokio::run(future::lazy(|| {
        tokio::spawn({
            let when = Instant::now() + Duration::from_millis(100);
            Delay::new(when)
                .and_then(move |_| {
                    println!("Delay 100 expired");
                    Ok(())
                })
                .map_err(|e| panic!("delay errored: {}", e))
        });

        tokio::spawn({
            let when = Instant::now() + Duration::from_millis(200);
            Delay::new(when)
                .and_then(move |_| {
                    println!("Delay 200 expired");
                    Ok(())
                })
                .map_err(|e| panic!("delay errored: {}", e))
        });

        future::ok::<_, ()>(())
    }))
}
...