about summary refs log tree commit diff
path: root/src/libstd/rt/select.rs
diff options
context:
space:
mode:
authortoddaaro <github@opprobrio.us>2013-08-05 13:06:24 -0700
committertoddaaro <github@opprobrio.us>2013-08-08 14:13:41 -0700
commitaf2e03998d4d06f2781ca72ec005f6913148f8bb (patch)
treefc65de2220eb4735ef6fdf554b5c7204ec41d6b1 /src/libstd/rt/select.rs
parenta0080f4e07891c89aa1f9851f8b0a3c754734fe8 (diff)
Enabled workstealing in the scheduler. Previously we had one global work queue shared by each scheduler. Now there is a separate work queue for each scheduler, and work is "stolen" from other queues when it is exhausted locally.
Diffstat (limited to 'src/libstd/rt/select.rs')
-rw-r--r--src/libstd/rt/select.rs2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/libstd/rt/select.rs b/src/libstd/rt/select.rs
index 006b777b71b..07f8ca77d9d 100644
--- a/src/libstd/rt/select.rs
+++ b/src/libstd/rt/select.rs
@@ -182,6 +182,7 @@ mod test {
     fn select_stream() {
         use util;
         use comm::GenericChan;
+        use iter::Times;
 
         // Sends 10 buffered packets, and uses select to retrieve them all.
         // Puts the port in a different spot in the vector each time.
@@ -265,6 +266,7 @@ mod test {
 
         fn select_racing_senders_helper(killable: bool, send_on_chans: ~[uint]) {
             use rt::test::spawntask_random;
+            use iter::Times;
 
             do run_in_newsched_task {
                 // A bit of stress, since ordinarily this is just smoke and mirrors.