1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
export anymap, seqmap, parmap;
fn anymap<T:send, U:send>(v: ~[T], f: fn~(T) -> U) -> ~[U] {
parmap(v, f)
}
fn seqmap<T, U>(v: ~[T], f: fn(T) -> U) -> ~[U] {
vec::map(v, f)
}
fn parmap<T:send, U:send>(v: ~[T], f: fn~(T) -> U) -> ~[U] unsafe {
let futures = do vec::map(v) |elt| {
let po = comm::port();
let ch = comm::chan(po);
let addr = ptr::addr_of(elt);
do task::spawn |copy f| {
comm::send(ch, f(*addr));
}
po
};
do vec::map(futures) |future| {
comm::recv(future)
}
}
#[test]
fn test_parallel_map() {
let i = ~[1, 2, 3, 4];
let j = parmap(i, |e| e + 1 );
assert j == ~[2, 3, 4, 5];
}
|
