OpenE2K
/
rust
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add a Racy type to bench tests

This commit is contained in:
Flavio Percoco 2014-12-24 12:59:23 +01:00
parent 29b3698f7f
commit 52072dec0f
2 changed files with 20 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/test/bench/shootout-reverse-complement.rs
View File

@ -46,7 +46,7 @@ extern crate libc;
use std::io::stdio::{stdin_raw, stdout_raw};
use std::num::{div_rem};
use std::ptr::{copy_memory};
use std::ptr::{copy_memory, Unique};
use std::io::{IoResult, EndOfFile};
struct Tables {
@ -219,10 +219,15 @@ fn reverse_complement(seq: &mut [u8], tables: &Tables) {
}
}
struct Racy<T>(T);
unsafe impl<T: 'static> Send for Racy<T> {}
/// Executes a closure in parallel over the given iterator over mutable slice.
/// The closure `f` is run in parallel with an element of `iter`.
fn parallel<'a, I, T, F>(mut iter: I, f: F)
where T: Send + Sync,
where T: 'a+Send + Sync,
I: Iterator<&'a mut [T]>,
F: Fn(&'a mut [T]) + Sync {
use std::mem;
@ -234,11 +239,11 @@ fn parallel<'a, I, T, F>(mut iter: I, f: F)
// Need to convert `f` and `chunk` to something that can cross the task
// boundary.
let f = &f as *const F as *const uint;
let raw = chunk.repr();
let f = Racy(&f as *const F as *const uint);
let raw = Racy(chunk.repr());
spawn(move|| {
let f = f as *const F;
unsafe { (*f)(mem::transmute(raw)) }
let f = f.0 as *const F;
unsafe { (*f)(mem::transmute(raw.0)) }
drop(tx)
});
}

13
src/test/bench/shootout-spectralnorm.rs
View File

@ -108,6 +108,11 @@ fn dot(v: &[f64], u: &[f64]) -> f64 {
v.iter().zip(u.iter()).map(|(a, b)| *a * *b).sum()
}
struct Racy<T>(T);
unsafe impl<T: 'static> Send for Racy<T> {}
// Executes a closure in parallel over the given mutable slice. The closure `f`
// is run in parallel and yielded the starting index within `v` as well as a
// sub-slice of `v`.
@ -122,11 +127,11 @@ fn parallel<'a, T, F>(v: &'a mut [T], f: F)
// Need to convert `f` and `chunk` to something that can cross the task
// boundary.
let f = &f as *const _ as *const uint;
let raw = chunk.repr();
let f = Racy(&f as *const _ as *const uint);
let raw = Racy(chunk.repr());
spawn(move|| {
let f = f as *const F;
unsafe { (*f)(i * size, mem::transmute(raw)) }
let f = f.0 as *const F;
unsafe { (*f)(i * size, mem::transmute(raw.0)) }
drop(tx)
});
}