embedded-threads 0.1.0

generic embedded scheduler & IPC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crate::arch::interrupt::CriticalSection;

use crate::{ThreadId, Threads};

pub(crate) struct ThreadList {
    pub head: Option<ThreadId>,
}

impl ThreadList {
    pub(crate) const fn new() -> Self {
        Self { head: None }
    }

    pub(crate) fn pop(&mut self, cs: &CriticalSection) -> Option<ThreadId> {
        if let Some(head) = self.head {
            let result = self.head;
            let thread = unsafe { &Threads::get_mut(cs).threads[head as usize] };
            self.head = thread.next;
            result
        } else {
            None
        }
    }
}