takeaway 0.1.0

An efficient work-stealing task queue with prioritization and batching.
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

//! Utility functionality.
//!
//! The code here is not directly relevant to `takeaway`, but it often proves
//! useful.

use alloc::vec::Vec;
use core::{mem::MaybeUninit, ptr};

mod executor;
pub use executor::block_on;

//----------- crossbeam_utils --------------------------------------------------
//
// '{backoff,cache_padded}.rs' are a vendored subset of the `crossbeam-utils`
// crate (version 0.8.21).

#[cfg(not(feature = "crossbeam-utils"))]
mod backoff;

#[cfg(not(feature = "crossbeam-utils"))]
mod cache_padded;

#[cfg(not(feature = "crossbeam-utils"))]
pub use backoff::Backoff;

#[cfg(not(feature = "crossbeam-utils"))]
pub use cache_padded::CachePadded;

#[cfg(feature = "crossbeam-utils")]
pub use crossbeam_utils::{Backoff, CachePadded};

//----------- extend_vec_from_slice() ------------------------------------------

/// Append elements of a slice to a [`Vec`].
///
/// # Safety
///
/// `slice` must contain initialized elements.  They will be moved out.
pub(crate) unsafe fn extend_vec_from_slice<T>(
    vec: &mut Vec<T>,
    slice: &[MaybeUninit<T>],
) {
    let len = vec.len();
    vec.reserve(slice.len());
    let src = slice;
    let dst = &mut vec.spare_capacity_mut()[..slice.len()];

    // SAFETY: 'src' and 'dst' are readable and writable, respectively.
    unsafe {
        ptr::copy_nonoverlapping(src.as_ptr(), dst.as_mut_ptr(), slice.len());
    }

    // SAFETY: 'src' contained 'slice.len()' initialized elements.
    unsafe { vec.set_len(len + slice.len()) };
}