pi_async 0.5.16

//! # 提供了异步运行时需要的队列和锁
//!

use std::hint::spin_loop;

pub mod mpmc_deque;
pub mod mpsc_deque;
pub mod steal_deque;
pub mod spin_lock;
pub mod mutex_lock;
pub mod rw_lock;

/*
* 根据指定值进行自旋，返回下次自旋的值
*/
#[inline]
pub(crate) fn spin(mut len: u32) -> u32 {
    if len < 1 {
        len = 1;
    } else if len > 10 {
        len = 10;
    }

    for _ in 0..(1 << len) {
        spin_loop()
    }

    len + 1
}