tg-rcore-tutorial-sync 0.4.8

use super::{Mutex, UPIntrFreeCell};
use alloc::{collections::VecDeque, sync::Arc};
use tg_task_manage::ThreadId;

/// Condvar
pub struct Condvar {
    /// UPIntrFreeCell<CondvarInner>
    pub inner: UPIntrFreeCell<CondvarInner>,
}

/// CondvarInner
pub struct CondvarInner {
    /// block queue
    pub wait_queue: VecDeque<ThreadId>,
}

impl Condvar {
    /// 创建一个新的条件变量。
    pub fn new() -> Self {
        Self {
            // SAFETY: 此条件变量仅在单处理器内核环境中使用
            inner: unsafe {
                UPIntrFreeCell::new(CondvarInner {
                    wait_queue: VecDeque::new(),
                })
            },
        }
    }
    /// 唤醒某个阻塞在当前条件变量上的线程
    pub fn signal(&self) -> Option<ThreadId> {
        let mut inner = self.inner.exclusive_access();
        inner.wait_queue.pop_front()
    }

    /*
    pub fn wait(&self) {
        let mut inner = self.inner.exclusive_access();
        inner.wait_queue.push_back(current_task().unwrap());
        drop(inner);
        block_current_and_run_next();
    }
    */
    /// 将当前线程阻塞在条件变量上
    pub fn wait_no_sched(&self, tid: ThreadId) -> bool {
        self.inner.exclusive_session(|inner| {
            inner.wait_queue.push_back(tid);
        });
        false
    }
    /// 从 mutex 的锁中释放一个线程，并将其阻塞在条件变量的等待队列中，等待其他线程运行完毕，当前的线程再试图获取这个锁
    ///
    /// 注意：下面是简化版的实现，在 mutex 唤醒一个线程之后，当前线程就直接获取这个 mutex，不管能不能获取成功
    /// 这里是单纯为了过测例，
    pub fn wait_with_mutex(
        &self,
        tid: ThreadId,
        mutex: Arc<dyn Mutex>,
    ) -> (bool, Option<ThreadId>) {
        // 教学提示：标准条件变量语义应包含“原子地解锁 + 入队 + 睡眠 + 被唤醒后重试加锁”。
        // 此处为教学简化实现，便于在章节中聚焦主流程。
        let waking_tid = mutex.unlock().unwrap();
        (mutex.lock(tid), Some(waking_tid))
    }
}