Method insert

crates/utilities/runtime/src/deterministic/executor.rs:116–125

Insert a new task into the running map and push it onto the ready queue.

(&self, future: Pin<Box<dyn Future<Output = ()> + Send>>)

impl Tasks {
    /// Insert a new task into the running map and push it onto the ready queue.
    pub fn insert(&self, future: Pin<Box<dyn Future<Output = ()> + Send>>) {
        let id = {
            let mut c = self.counter.lock().unwrap();
            let id = *c;
            *c += 1;
            id
        };
        self.running.lock().unwrap().insert(id, Arc::new(Task { future: Mutex::new(future) }));
        self.queue(id);
    }

    /// Push a task ID onto the ready queue (called by `TaskWaker`).
    pub fn queue(&self, id: u128) {