Skip to content

Commit fba5925

Browse files
committed
---
yaml --- r: 142581 b: refs/heads/try2 c: dec9db1 h: refs/heads/master i: 142579: 428b586 v: v3
1 parent 0431398 commit fba5925

File tree

3 files changed

+50
-1
lines changed

3 files changed

+50
-1
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ refs/heads/snap-stage3: 78a7676898d9f80ab540c6df5d4c9ce35bb50463
55
refs/heads/try: 519addf6277dbafccbb4159db4b710c37eaa2ec5
66
refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
77
refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
8-
refs/heads/try2: 3f8095e55043f35e08adba5fe5b0a2d687ebc514
8+
refs/heads/try2: dec9db10da062b1c528d46426d9f62e201d39bc6
99
refs/heads/dist-snap: ba4081a5a8573875fed17545846f6f6902c8ba8d
1010
refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
1111
refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503

branches/try2/src/libcore/rt/mod.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,9 @@ mod work_queue;
8888
/// A parallel queue.
8989
mod message_queue;
9090

91+
/// A parallel data structure for tracking sleeping schedulers.
92+
mod sleeper_list;
93+
9194
/// Stack segments and caching.
9295
mod stack;
9396

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
// Copyright 2013 The Rust Project Developers. See the COPYRIGHT
2+
// file at the top-level directory of this distribution and at
3+
// http://rust-lang.org/COPYRIGHT.
4+
//
5+
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
6+
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
7+
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
8+
// option. This file may not be copied, modified, or distributed
9+
// except according to those terms.
10+
11+
//! Maintains a shared list of sleeping schedulers. Schedulers
12+
//! use this to wake each other up.
13+
14+
use container::Container;
15+
use vec::OwnedVector;
16+
use option::{Option, Some, None};
17+
use cell::Cell;
18+
use unstable::sync::{Exclusive, exclusive};
19+
use rt::sched::{Scheduler, SchedHandle};
20+
21+
pub struct SleeperList {
22+
priv stack: ~Exclusive<~[SchedHandle]>
23+
}
24+
25+
impl SleeperList {
26+
pub fn new() -> SleeperList {
27+
SleeperList {
28+
stack: ~exclusive(~[])
29+
}
30+
}
31+
32+
pub fn push(&mut self, handle: SchedHandle) {
33+
let handle = Cell(handle);
34+
self.stack.with(|s| s.push(handle.take()));
35+
}
36+
37+
pub fn pop(&mut self) -> Option<SchedHandle> {
38+
do self.stack.with |s| {
39+
if !s.is_empty() {
40+
Some(s.pop())
41+
} else {
42+
None
43+
}
44+
}
45+
}
46+
}

0 commit comments

Comments
 (0)