Method split

src/job.rs:186–201

Splits off a series of chunks from the end of the queue (the side with the newest jobs). Each chunk is of size `CHUNK_SIZE`. Afterwards, at most `CHUNK_SIZE` jobs will remain in the queue.

(&self)

    }

    /// The size of a chunk of jobs.
    const CHUNK_SIZE: usize = 16;

    /// Splits off a series of chunks from the end of the queue (the side with
    /// the newest jobs). Each chunk is of size `CHUNK_SIZE`. Afterwards, at most
    /// `CHUNK_SIZE` jobs will remain in the queue.
    pub fn split(&self) -> Vec<VecDeque<JobRef>> {
        // SAFETY: We have unique access to `job_refs` (see the field
        // invariant).
        let job_refs = unsafe { &mut *self.job_refs.get() };
        let mut len = job_refs.len();
        let num_chunks = len / Self::CHUNK_SIZE;
        (0..num_chunks)
            .map(|_| {
                let chunk = job_refs.split_off(len - Self::CHUNK_SIZE);
                len -= Self::CHUNK_SIZE;
                chunk
            })
            .collect()