a simple parallel computing framework inspired by openmp and implemented in scala
1, Hello World:
import parallelframework.ScalaMp
import parallelframework.ScalaMp._
ScalaMp parallel withThread(8) op{ (my_rank, threadNum) =>
println(s"hello world , my_rank: $my_rank, threadNum: $threadNum")
}###output:
hello world , my_rank: 5, threadNum: 8
hello world , my_rank: 0, threadNum: 8
hello world , my_rank: 6, threadNum: 8
hello world , my_rank: 3, threadNum: 8
hello world , my_rank: 4, threadNum: 8
hello world , my_rank: 7, threadNum: 8
hello world , my_rank: 2, threadNum: 8
hello world , my_rank: 1, threadNum: 8 var start = System.currentTimeMillis
var pi = 0.0
val n = 100000000
ScalaMp parallel_for(0 until n, Default_Schedule_Static) withThread(100) each{ (my_rank, threadNum, range) =>
var factor = if(range(0) % 2 == 0) 1.0 else -1.0
val local_result = (0.0 /: range){ (acc, elem) =>
val temp = factor / (2 * elem + 1)
factor = -factor
acc + temp
}
critical{
pi += local_result
}
}
println(s"pi = ${pi * 4.0}")
println(s"parallel Time: ${System.currentTimeMillis - start}")###output:
pi = 3.141592643589774
parallel Time: 2485