From f1c22a0b4c2f4a9e29140d409e7d10d86cd844bb Mon Sep 17 00:00:00 2001 From: Tshepang Lekhonkhobe Date: Mon, 26 Jan 2015 21:21:06 +0200 Subject: [PATCH] bench: this file has not compiled at least since March last year See 579eb2400b3cb5d9cf03a5c8792d63630489193a --- src/test/bench/task-perf-one-million.rs | 70 ------------------------- 1 file changed, 70 deletions(-) delete mode 100644 src/test/bench/task-perf-one-million.rs diff --git a/src/test/bench/task-perf-one-million.rs b/src/test/bench/task-perf-one-million.rs deleted file mode 100644 index e3b51cb6b5b..00000000000 --- a/src/test/bench/task-perf-one-million.rs +++ /dev/null @@ -1,70 +0,0 @@ -// Copyright 2012-2014 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. - -// Test for concurrent tasks - -// ignore-test OOM on linux-32 without opts - -use std::os; -use std::task; -use std::uint; -use std::slice; - -fn calc(children: uint, parent_wait_chan: &Sender>>) { - - let wait_ports: Vec>>> = vec::from_fn(children, |_| { - let (wait_port, wait_chan) = stream::>>(); - task::spawn(move|| { - calc(children / 2, &wait_chan); - }); - wait_port - }); - - let child_start_chans: Vec>> = - wait_ports.into_iter().map(|port| port.recv()).collect(); - - let (start_port, start_chan) = stream::>(); - parent_wait_chan.send(start_chan); - let parent_result_chan: Sender = start_port.recv(); - - let child_sum_ports: Vec> = - child_start_chans.into_iter().map(|child_start_chan| { - let (child_sum_port, child_sum_chan) = stream::(); - child_start_chan.send(child_sum_chan); - child_sum_port - }).collect(); - - let sum = child_sum_ports.into_iter().fold(0, |sum, sum_port| sum + sum_port.recv() ); - - parent_result_chan.send(sum + 1); -} - -fn main() { - let args = os::args(); - let args = if os::getenv("RUST_BENCH").is_some() { - vec!("".to_string(), "30".to_string()) - } else if args.len() <= 1u { - vec!("".to_string(), "10".to_string()) - } else { - args - }; - - let children = from_str::(args[1]).unwrap(); - let (wait_port, wait_chan) = stream(); - task::spawn(move|| { - calc(children, &wait_chan); - }); - - let start_chan = wait_port.recv(); - let (sum_port, sum_chan) = stream::(); - start_chan.send(sum_chan); - let sum = sum_port.recv(); - println!("How many tasks? {} tasks.", sum); -}