jay-compositor 1.15.0

The Jay compositor
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

use crate::async_engine::AsyncEngine;
use crate::async_engine::SpawnedFuture;
use crate::utils::queue::AsyncQueue;
use std::cell::Cell;
use std::rc::Rc;

pub struct RunToplevelFuture {
    _future: SpawnedFuture<()>,
}

pub struct RunToplevel {
    cleared: Cell<bool>,
    queue: AsyncQueue<Box<dyn FnOnce()>>,
}

impl RunToplevel {
    pub fn install(eng: &Rc<AsyncEngine>) -> (RunToplevelFuture, Rc<RunToplevel>) {
        let slf = Rc::new(RunToplevel {
            cleared: Default::default(),
            queue: Default::default(),
        });
        let future = eng.spawn("run toplevel", {
            let slf = slf.clone();
            async move {
                loop {
                    let f = slf.queue.pop().await;
                    f();
                }
            }
        });
        let future = RunToplevelFuture { _future: future };
        (future, slf)
    }

    pub fn schedule<F: FnOnce() + 'static>(&self, f: F) {
        self.schedule_dyn(Box::new(f));
    }

    pub fn clear(&self) {
        self.cleared.set(true);
        self.queue.clear();
    }

    fn schedule_dyn(&self, f: Box<dyn FnOnce()>) {
        if self.cleared.get() {
            return;
        }
        self.queue.push(f);
    }
}