pub fn new() -> Queue {
        Queue {
            global: Arc::new(Global {
                queue: ConcurrentQueue::unbounded(),
                shards: RwLock::new(Slab::new()),
                notified: AtomicBool::new(true),
                sleepers: Mutex::new(Sleepers {
                    count: 0,
                    callbacks: Vec::new(),
                }),
            }),
        }
    }
/// Creates a new queue for spawning futures.
Creates a new queue for spawning futures.
Creates a new queue for spawning futures .
pub fn new() -> Queue {
        Queue {
            global: Arc::new(Global {
                queue: ConcurrentQueue::unbounded(),
                shards: RwLock::new(Slab::new()),
                notified: AtomicBool::new(true),
                sleepers: Mutex::new(Sleepers {
                    count: 0,
                    callbacks: Vec::new(),
                }),
            }),
        }
    }
pub fn new ( ) -> Queue { Queue { global : Arc :: new ( Global { queue : ConcurrentQueue :: unbounded ( ) , shards : RwLock :: new ( Slab :: new ( ) ) , notified : AtomicBool :: new ( true ) , sleepers : Mutex :: new ( Sleepers { count : 0 , callbacks : Vec :: new ( ) , } ) , } ) , } }
Creates a new queue for spawning futures.
Creates a new queue for spawning futures .