blob: ad1bbcfe30d3e12ac2373608cfb363caf299b85c (
plain) (
blame)
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
import scala.collection.JavaConverters._
object Test extends App {
def bench(label: String)(body: => Unit): Long = {
val start = System.nanoTime
0.until(10).foreach(_ => body)
val end = System.nanoTime
//println("%s: %s ms".format(label, (end - start) / 1000.0 / 1000.0))
end - start
}
def benchJava(values: java.util.Map[Int, Int]) = {
bench("Java Map") {
val m = new java.util.HashMap[Int, Int]
m.putAll(values)
}
}
def benchScala(values: Iterable[(Int, Int)]) = {
bench("Scala Map") {
val m = new scala.collection.mutable.HashMap[Int, Int]
m ++= values
}
}
def benchScalaSorted(values: Iterable[(Int, Int)]) = {
bench("Scala Map sorted") {
val m = new scala.collection.mutable.HashMap[Int, Int]
m ++= values.toArray.sorted
}
}
def benchScalaPar(values: Iterable[(Int, Int)]) = {
bench("Scala ParMap") {
val m = new scala.collection.parallel.mutable.ParHashMap[Int, Int] map { x => x }
m ++= values
}
}
val total = 50000
val values = (0 until total) zip (0 until total)
val map = scala.collection.mutable.HashMap.empty[Int, Int]
map ++= values
// warmup
for (x <- 0 until 5) {
benchJava(map.asJava)
benchScala(map)
benchScalaPar(map)
benchJava(map.asJava)
benchScala(map)
benchScalaPar(map)
}
val javamap = benchJava(map.asJava)
val scalamap = benchScala(map)
val scalaparmap = benchScalaPar(map)
// println(javamap)
// println(scalamap)
// println(scalaparmap)
assert(scalamap < (javamap * 10), "scalamap: " + scalamap + " vs. javamap: " + javamap)
assert(scalaparmap < (javamap * 10), "scalaparmap: " + scalaparmap + " vs. javamap: " + javamap)
}
|
