Method new

src/executors/skip_executor.rs:18–47

(executor: Executor)

}

impl SkipExecutor {
    pub(crate) fn new(executor: Executor) -> (Self, Sender<()>) {
        let (tx, mut rx) = channel::<()>(10);
        let is_skip = Arc::new(AtomicBool::new(false));

        // 创建定时器
        let timer = slint::Timer::default();

        let executor = Self {
            timer,
            executor,
            is_skip: is_skip.clone(),
        };

        // 监听控制信号的任务
        let is_skip_clone = is_skip.clone();
        tokio::spawn(async move {
            let mut start = true;
            while rx.recv().await.is_some() {
                if start {
                    is_skip_clone.store(true, Ordering::Relaxed);
                    start = false;
                } else {
                    is_skip_clone.store(false, Ordering::Relaxed);
                    start = true;
                }
            }
        });

        (executor, tx)
    }

    pub(crate) fn start_timer(&mut self) {