// Copyright 2013 The Rust Project Developers. See the COPYRIGHT // file at the top-level directory of this distribution and at // http://rust-lang.org/COPYRIGHT. // // Licensed under the Apache License, Version 2.0 or the MIT license // , at your // option. This file may not be copied, modified, or distributed // except according to those terms. //! Maintains a shared list of sleeping schedulers. Schedulers //! use this to wake each other up. use std::sync::mpmc_bounded_queue::Queue; use sched::SchedHandle; pub struct SleeperList { q: Queue, } impl SleeperList { pub fn new() -> SleeperList { SleeperList{q: Queue::with_capacity(8*1024)} } pub fn push(&mut self, value: SchedHandle) { assert!(self.q.push(value)) } pub fn pop(&mut self) -> Option { self.q.pop() } pub fn casual_pop(&mut self) -> Option { self.q.pop() } } impl Clone for SleeperList { fn clone(&self) -> SleeperList { SleeperList { q: self.q.clone() } } }