vtcode-core 0.104.1

Core library for VT Code - a Rust-based terminal coding agent
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

use std::collections::VecDeque;

use tokio::sync::Mutex;

use super::ScheduledWork;

/// Simple queue-backed scheduler with FIFO ordering.
#[derive(Debug, Default)]
pub struct Scheduler {
    queue: Mutex<VecDeque<ScheduledWork>>,
}

impl Scheduler {
    pub fn new() -> Self {
        Self {
            queue: Mutex::new(VecDeque::new()),
        }
    }

    pub async fn enqueue(&self, work: ScheduledWork) {
        let mut queue = self.queue.lock().await;
        queue.push_back(work);
    }

    pub async fn next(&self) -> Option<ScheduledWork> {
        let mut queue = self.queue.lock().await;
        queue.pop_front()
    }

    pub async fn queue_depth(&self) -> usize {
        let queue = self.queue.lock().await;
        queue.len()
    }
}