diff options
| author | toddaaro <github@opprobrio.us> | 2013-08-05 13:06:24 -0700 |
|---|---|---|
| committer | toddaaro <github@opprobrio.us> | 2013-08-08 14:13:41 -0700 |
| commit | af2e03998d4d06f2781ca72ec005f6913148f8bb (patch) | |
| tree | fc65de2220eb4735ef6fdf554b5c7204ec41d6b1 /src/libstd/rt/select.rs | |
| parent | a0080f4e07891c89aa1f9851f8b0a3c754734fe8 (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.rs | 2 |
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. |
