lamellar 0.8.0

Lamellar is an asynchronous tasking runtime for HPC systems developed in RUST.
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
32
33

use lamellar::array::prelude::*;

struct ArrayWrapper<T: Dist> {
    _array: AtomicArray<T>,
}

impl<T: Dist + ArrayOps + Default> ArrayWrapper<T> {
    fn new(world: LamellarWorld, len: usize) -> Self {
        ArrayWrapper {
            _array: AtomicArray::<T>::new(world, len, Distribution::Block).block(),
        }
    }
}

// lamellar::generate_ops_for_type!(false, Option<u8>); //todo get this to work... which Im not sure is actually possible?

#[lamellar::main]
fn main() {
    let world = lamellar::LamellarWorldBuilder::new().build();
    let _my_pe = world.my_pe();
    let num_pes = world.num_pes();
    let _wrapped_array_f32 = ArrayWrapper::<f32>::new(world.clone(), 10 * num_pes);
    let _wrapped_array_usize = ArrayWrapper::<usize>::new(world.clone(), 10 * num_pes);
    // let wrapped_array_option_u8 = ArrayWrapper::<Option<u8>>::new(world.clone(), 10 * num_pes); //todo get this to work...
    // wrapped_array_f32.array.print();
    // wrapped_array_usize.array.print();
}
//     wrapped_array_option_u8.array.compare_exchange(0,None,Some(1));
//     wrapped_array_option_u8.array.compare_exchange(7,None,Some(7));
//     wrapped_array_option_u8.array.wait_all();
//     wrapped_array_option_u8.array.barrier();
//     wrapped_array_option_u8.array.print();
// }